azkaban-developers

diff --git a/src/java/azkaban/executor/FlowRunner.java b/src/java/azkaban/executor/FlowRunner.java
index d0c0dc6..09628b4 100644
--- a/src/java/azkaban/executor/FlowRunner.java
+++ b/src/java/azkaban/executor/FlowRunner.java
@@ -390,8 +390,7 @@ public class FlowRunner extends EventHandler implements Runnable {
 					logger.info("Flow is paused so adding "
 							+ dependentNode.getId() + " to paused list.");
 				} else {
-					logger.info("Flow is not paused so adding "
-							+ dependentNode.getId() + " to paused list.");
+					logger.info("Adding " + dependentNode.getId() + " to run queue.");
 					jobsToRun.add(runner);
 				}
 			}

diff --git a/src/java/azkaban/executor/JobRunner.java b/src/java/azkaban/executor/JobRunner.java
index ff5f1e4..3a5c99c 100644
--- a/src/java/azkaban/executor/JobRunner.java
+++ b/src/java/azkaban/executor/JobRunner.java
@@ -90,15 +90,6 @@ public class JobRunner extends EventHandler implements Runnable {
 		node.setStatus(Status.RUNNING);
 		this.fireEventListeners(Event.create(this, Type.JOB_STARTED));
 
-		synchronized(this) {
-			try {
-				wait(5000);
-			}
-			catch (InterruptedException e) {
-				logger.info("Job cancelled.");
-			}
-		}
-
 		// Run Job
 		boolean succeeded = true;
 
@@ -130,7 +121,7 @@ public class JobRunner extends EventHandler implements Runnable {
 	public synchronized void cancel() {
 		// Cancel code here
 		if(job == null) {
-            logger.error("Job doesn't exisit!");
+            logger.error("Job doesn't exist!");
             return;
 		}