Browse Source

fix complement data retry bug; issues: [Bug] [Master] A bug on task retry mechanism #6613 (#6843)

Co-authored-by: yangqiyu <yangqiyu@deepexi.com>
3.0.0/version-upgrade
KyoYang 3 years ago committed by GitHub
parent
commit
94f6c5c27e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 2
      dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java

2
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java

@ -1007,7 +1007,7 @@ public class WorkflowExecuteThread implements Runnable {
return true;
}
if (processInstance.getFailureStrategy() == FailureStrategy.CONTINUE) {
return readyToSubmitTaskQueue.size() == 0 || activeTaskProcessorMaps.size() == 0;
return readyToSubmitTaskQueue.size() == 0 && activeTaskProcessorMaps.size() == 0;
}
}
return false;

Loading…
Cancel
Save