Browse Source

[BUG-12361] complement data by serial execution, after a failed process instance, subsequent process instances are not generated (#12488)

2.0.8-release
Molin Wang 2 years ago committed by GitHub
parent
commit
b2d682ed31
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 4
      dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java

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

@ -539,9 +539,9 @@ public class WorkflowExecuteThread implements Runnable {
return true;
}
int index = complementListDate.indexOf(scheduleDate);
if (index >= complementListDate.size() - 1 || !processInstance.getState().typeIsSuccess()) {
if (index >= complementListDate.size() - 1) {
logger.info("process complement end. process id:{}", processInstance.getId());
// complement data ends || no success
// complement data ends
return true;
}
logger.info("process complement continue. process id:{}, schedule time:{} complementListDate:{}",

Loading…
Cancel
Save