azkaban-aplcache

Increasing the job cancel time from 5 sec to 30 sec (#1011) For

4/24/2017 3:09:33 PM

Details

diff --git a/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java b/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java
index 221e5f3..eff10e3 100644
--- a/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java
+++ b/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java
@@ -19,6 +19,7 @@ package azkaban.jobExecutor;
 import azkaban.Constants;
 import azkaban.metrics.CommonMetrics;
 import java.io.File;
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -40,7 +41,7 @@ public class ProcessJob extends AbstractProcessJob {
 
   public static final String COMMAND = "command";
 
-  private static final long KILL_TIME_MS = 5000;
+  private static final Duration KILL_TIME = Duration.ofSeconds(30);
 
   private volatile AzkabanProcess process;
 
@@ -300,7 +301,7 @@ public class ProcessJob extends AbstractProcessJob {
 
     if (process == null)
       throw new IllegalStateException("Not started.");
-    boolean processkilled = process.softKill(KILL_TIME_MS, TimeUnit.MILLISECONDS);
+    boolean processkilled = process.softKill(KILL_TIME.toMillis(), TimeUnit.MILLISECONDS);
     if (!processkilled) {
       warn("Kill with signal TERM failed. Killing with KILL signal.");
       process.hardKill();