azkaban-aplcache

Revert "uploadExecutableNode improvement (#1167)" (#1185) This

6/12/2017 5:01:58 PM
3.28.0

Details

diff --git a/azkaban-exec-server/src/main/java/azkaban/execapp/JobRunner.java b/azkaban-exec-server/src/main/java/azkaban/execapp/JobRunner.java
index 3895cf1..2ee9d67 100644
--- a/azkaban-exec-server/src/main/java/azkaban/execapp/JobRunner.java
+++ b/azkaban-exec-server/src/main/java/azkaban/execapp/JobRunner.java
@@ -584,9 +584,8 @@ public class JobRunner extends EventHandler implements Runnable {
     // Start the node.
     this.node.setStartTime(System.currentTimeMillis());
     Status finalStatus = this.node.getStatus();
-    if (!uploadExecutableNode()) {
-      finalStatus = changeStatus(Status.FAILED);
-    } else if (!errorFound && !isKilled()) {
+    uploadExecutableNode();
+    if (!errorFound && !isKilled()) {
       fireEvent(Event.create(this, Type.JOB_STARTED, new EventData(this.node)));
 
       final Status prepareStatus = prepareJob();
@@ -623,13 +622,11 @@ public class JobRunner extends EventHandler implements Runnable {
     writeStatus();
   }
 
-  private boolean uploadExecutableNode() {
+  private void uploadExecutableNode() {
     try {
       this.loader.uploadExecutableNode(this.node, this.props);
-      return true;
     } catch (final ExecutorManagerException e) {
       this.logger.error("Error writing initial node properties", e);
-      return false;
     }
   }