azkaban-aplcache

Improve InteractiveTestJob stability (#1364) Wait for

8/18/2017 5:16:33 PM

Details

diff --git a/azkaban-common/src/test/java/azkaban/executor/InteractiveTestJob.java b/azkaban-common/src/test/java/azkaban/executor/InteractiveTestJob.java
index 6aad32f..5ca9993 100644
--- a/azkaban-common/src/test/java/azkaban/executor/InteractiveTestJob.java
+++ b/azkaban-common/src/test/java/azkaban/executor/InteractiveTestJob.java
@@ -40,7 +40,7 @@ public class InteractiveTestJob extends AbstractProcessJob {
   }
 
   public static InteractiveTestJob getTestJob(final String name) {
-    for (int i = 0; i < 100; i++) {
+    for (int i = 0; i < 1000; i++) {
       if (testJobs.containsKey(name)) {
         return testJobs.get(name);
       }
@@ -48,6 +48,7 @@ public class InteractiveTestJob extends AbstractProcessJob {
         try {
           InteractiveTestJob.testJobs.wait(10L);
         } catch (final InterruptedException e) {
+          i--;
         }
       }
     }