azkaban-aplcache

Details

diff --git a/azkaban-exec-server/src/main/java/azkaban/execapp/FlowRunner.java b/azkaban-exec-server/src/main/java/azkaban/execapp/FlowRunner.java
index 603af51..c2d84eb 100644
--- a/azkaban-exec-server/src/main/java/azkaban/execapp/FlowRunner.java
+++ b/azkaban-exec-server/src/main/java/azkaban/execapp/FlowRunner.java
@@ -193,8 +193,6 @@ public class FlowRunner extends EventHandler implements Runnable {
       setupFlowExecution();
       this.flow.setStartTime(System.currentTimeMillis());
 
-      updateFlowReference();
-
       this.logger.info("Updating initial flow directory.");
       updateFlow();
       this.logger.info("Fetching job and shared properties.");
@@ -273,15 +271,6 @@ public class FlowRunner extends EventHandler implements Runnable {
     this.flowRunnerThread.setName("FlowRunner-exec-" + this.flow.getExecutionId());
   }
 
-  private void updateFlowReference() throws ExecutorManagerException {
-    this.logger.info("Update active reference");
-    if (!this.executorLoader.updateExecutableReference(this.execId,
-        System.currentTimeMillis())) {
-      throw new ExecutorManagerException(
-          "The executor reference doesn't exist. May have been killed prematurely.");
-    }
-  }
-
   private void updateFlow() {
     updateFlow(System.currentTimeMillis());
   }