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());
}