From e6f727b16e1e2705395d4f5cb4b135b3520c865e Mon Sep 17 00:00:00 2001
From: Molin Wang <wcmolin@gmail.com>
Date: Mon, 13 Mar 2023 16:59:02 +0800
Subject: [PATCH] Roll back the logic of execution complement failure stop
 (#13723)

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