This is an automated email from the ASF dual-hosted git repository.
jinyleechina pushed a commit to branch 2.0.9-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/2.0.9-prepare by this push:
new e6f727b16e Roll back the logic of execution complement failure stop
(#13723)
e6f727b16e is described below
commit e6f727b16e1e2705395d4f5cb4b135b3520c865e
Author: Molin Wang <[email protected]>
AuthorDate: Mon Mar 13 16:59:02 2023 +0800
Roll back the logic of execution complement failure stop (#13723)
---
.../dolphinscheduler/server/master/runner/WorkflowExecuteThread.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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
index 2dba7b2a18..abce1ecf2b 100644
---
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 @@ public class WorkflowExecuteThread implements Runnable {
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:{}",