Repository: helix Updated Branches: refs/heads/master 964397081 -> cee95c51a (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/ae8e8e2e Tree: http://git-wip-us.apache.org/repos/asf/helix/tree/ae8e8e2e Diff: http://git-wip-us.apache.org/repos/asf/helix/diff/ae8e8e2e Branch: refs/heads/master Commit: ae8e8e2ef37f48d782fc12f85ca97728cf2b70c4 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:12:10 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/ae8e8e2e/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
