Browse Source

[Fix-12586] [Master] Repeat running the complement process instance will generate redundant complement instances (#12606)

2.0.8-release
Molin Wang 2 years ago committed by GitHub
parent
commit
c204b39dfd
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

@ -534,6 +534,10 @@ public class WorkflowExecuteThread implements Runnable {
scheduleDate = complementListDate.get(0); scheduleDate = complementListDate.get(0);
} else if (processInstance.getState().typeIsFinished()) { } else if (processInstance.getState().typeIsFinished()) {
endProcess(); endProcess();
// rerun process instance of complement didn't need create the next process complement
if (processInstance.getCommandType() == CommandType.REPEAT_RUNNING) {
return true;
}
if (complementListDate.size() <= 0) { if (complementListDate.size() <= 0) {
logger.info("process complement end. process id:{}", processInstance.getId()); logger.info("process complement end. process id:{}", processInstance.getId());
return true; return true;

Loading…
Cancel
Save