helix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [1/2] helix git commit: waitToJob should wait only if job status is IN_PROGRESS
Date Fri, 26 Jan 2018 20:05:27 GMT
Repository: helix
Updated Branches:
  refs/heads/master 22cc4a4d4 -> 7b3c6d47d


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/c5772d97
Tree: http://git-wip-us.apache.org/repos/asf/helix/tree/c5772d97
Diff: http://git-wip-us.apache.org/repos/asf/helix/diff/c5772d97

Branch: refs/heads/master
Commit: c5772d97845f632ffa10e623e048654efebb95f4
Parents: 22cc4a4
Author: Eric Kim <erkim@erkim-mn1.linkedin.biz>
Authored: Thu Jan 25 18:03:55 2018 -0800
Committer: Eric Kim <erkim@erkim-mn1.linkedin.biz>
Committed: Thu Jan 25 18:03:55 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/c5772d97/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


Mime
View raw message