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:{}",

Reply via email to