Roll back the logic of execution complement failure stop

wcmolin · wcmolin · commit f96b2424c5ce · 2023-03-11T19:48:39.000+08:00
diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java
@@ -553,9 +553,9 @@ private boolean processComplementData() {
                 return true;
             }
             int index = complementListDate.indexOf(scheduleDate);
-            if (index >= complementListDate.size() - 1) {
+            if (index >= complementListDate.size() - 1 || !processInstance.getState().typeIsSuccess()) {
                 logger.info("process complement end. process id:{}", processInstance.getId());
-                // complement data ends
+                // complement data ends || no success
                 return true;
             }
             logger.info("process complement continue. process id:{}, schedule time:{} complementListDate:{}",

Original file line number	Diff line number	Diff line change
`@@ -553,9 +553,9 @@ private boolean processComplementData() {`
`553`	`553`	`return true;`
`554`	`554`	`}`
`555`	`555`	`int index = complementListDate.indexOf(scheduleDate);`
`556`		`- if (index >= complementListDate.size() - 1) {`
	`556`	`+ if (index >= complementListDate.size() - 1 \|\| !processInstance.getState().typeIsSuccess()) {`
`557`	`557`	`logger.info("process complement end. process id:{}", processInstance.getId());`
`558`		`- // complement data ends`
	`558`	`+ // complement data ends \|\| no success`
`559`	`559`	`return true;`
`560`	`560`	`}`
`561`	`561`	`logger.info("process complement continue. process id:{}, schedule time:{} complementListDate:{}",`