azkaban-aplcache

Revert unexpected change

9/23/2015 7:04:03 PM

evlstyle

Commit: 2da9aac

Tree: ce7c799

Parents: bc76a37

Changes

azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java 2(+1 -1)

Details

azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java 2(+1 -1)

diff --git a/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java b/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java
index 392c649..9623433 100644
--- a/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java
+++ b/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java
@@ -1790,7 +1790,7 @@ public class ExecutorManager extends EventHandler implements
     private void processQueuedFlows(long activeExecutorsRefreshWindow,
       int maxContinuousFlowProcessed) throws InterruptedException,
       ExecutorManagerException {
-      long lastExecutorRefreshTime = 0;
+      long lastExecutorRefreshTime = System.currentTimeMillis();
       Pair<ExecutionReference, ExecutableFlow> runningCandidate;
       int currentContinuousFlowProcessed = 0;