azkaban-aplcache

fix race condition between killing job and initializing job …

6/28/2017 8:28:12 PM

(#1253)

Cheng Ren

Commit: 7aff4b6

Tree: d2e9362

Parents: 4e4aa25

Changes

azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java 6(+4 -2)

Details

azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java 6(+4 -2)

diff --git a/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java b/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java
index 02a9abe..9d49543 100644
--- a/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java
+++ b/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java
@@ -247,8 +247,10 @@ public class ProcessJob extends AbstractProcessJob {
       this.process = builder.build();
 
       try {
-        this.process.run();
-        success = true;
+        if (!this.killed) {
+          this.process.run();
+          success = true;
+        }
       } catch (final Throwable e) {
         for (final File file : propFiles) {
           if (file != null && file.exists()) {