Repository: helix Updated Branches: refs/heads/master b8a40d019 -> 964397081 (forced update)
waitToJob should wait only if job status is IN_PROGRESS Project: http://git-wip-us.apache.org/repos/asf/helix/repo Commit: http://git-wip-us.apache.org/repos/asf/helix/commit/494b03cd Tree: http://git-wip-us.apache.org/repos/asf/helix/tree/494b03cd Diff: http://git-wip-us.apache.org/repos/asf/helix/diff/494b03cd Branch: refs/heads/master Commit: 494b03cde8a562790618cf6a7bd66d44588585ab Parents: 22cc4a4 Author: Eric Kim <[email protected]> Authored: Thu Jan 25 18:03:55 2018 -0800 Committer: Junkai Xue <[email protected]> Committed: Mon Jan 29 18:04:34 2018 -0800 ---------------------------------------------------------------------- helix-core/src/main/java/org/apache/helix/task/TaskDriver.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/helix/blob/494b03cd/helix-core/src/main/java/org/apache/helix/task/TaskDriver.java ---------------------------------------------------------------------- diff --git a/helix-core/src/main/java/org/apache/helix/task/TaskDriver.java b/helix-core/src/main/java/org/apache/helix/task/TaskDriver.java index 99fa761..f434ae3 100644 --- a/helix-core/src/main/java/org/apache/helix/task/TaskDriver.java +++ b/helix-core/src/main/java/org/apache/helix/task/TaskDriver.java @@ -519,8 +519,7 @@ public class TaskDriver { while (System.currentTimeMillis() <= endTime) { WorkflowContext workflowContext = getWorkflowContext(workflow); - if (workflowContext == null || !workflowContext.getWorkflowState() - .equals(TaskState.STOPPED)) { + if (workflowContext == null || TaskState.IN_PROGRESS.equals(workflowContext.getWorkflowState())) { Thread.sleep(1000); } else { // Successfully stopped
