azkaban-aplcache

Details

diff --git a/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java b/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java
index 12e50e0..cffabe7 100644
--- a/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java
+++ b/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java
@@ -429,13 +429,6 @@ public class ExecutorManager extends EventHandler implements
 
   private void loadRunningFlows() throws ExecutorManagerException {
     runningFlows.putAll(executorLoader.fetchActiveFlows());
-    // Finalize all flows which were running on an executor which is now
-    // inactive
-    for (Pair<ExecutionReference, ExecutableFlow> pair : runningFlows.values()) {
-      if (!activeExecutors.contains(pair.getFirst().getExecutor())) {
-        finalizeFlows(pair.getSecond());
-      }
-    }
   }
 
   /*