Browse Source

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

Co-authored-by: yangqiyu <yangqiyu@deepexi.com>

Co-authored-by: KyoYang <39785282+yangqiyu0306@users.noreply.github.com>
Co-authored-by: yangqiyu <yangqiyu@deepexi.com>
2.0.7-release
JinYong Li 3 years ago committed by GitHub
parent
commit
92347a73e0
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

@ -979,7 +979,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