From 94f6c5c27ee88d5ec6f7f3856b2bc2aebab738e8 Mon Sep 17 00:00:00 2001
From: KyoYang <39785282+yangqiyu0306@users.noreply.github.com>
Date: Mon, 15 Nov 2021 01:05:13 +0800
Subject: [PATCH] fix complement data retry bug; issues: [Bug] [Master] A bug
 on task retry mechanism #6613 (#6843)

Co-authored-by: yangqiyu <yangqiyu@deepexi.com>
---
 .../server/master/runner/WorkflowExecuteThread.java             | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 54792ca519..ad12abeb7d 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
@@ -1007,7 +1007,7 @@ public class WorkflowExecuteThread implements Runnable {
                 return true;
             }
             if (processInstance.getFailureStrategy() == FailureStrategy.CONTINUE) {
-                return readyToSubmitTaskQueue.size() == 0 || activeTaskProcessorMaps.size() == 0;
+                return readyToSubmitTaskQueue.size() == 0 && activeTaskProcessorMaps.size() == 0;
             }
         }
         return false;