From 520e72f3de333ccee684351b9212148fb0110b4e Mon Sep 17 00:00:00 2001
From: weeway <geverway@gmail.com>
Date: Fri, 1 Jul 2022 17:21:26 +0800
Subject: [PATCH] [Fix-10443][server]fix dependent task always running (#10708)

* [Fix-10443][server]fix dependent task always running

* optimize remove logic
---
 .../server/master/runner/WorkflowExecuteThread.java          | 5 ++---
 1 file changed, 2 insertions(+), 3 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 1a0866f6f2..411c07b2a1 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
@@ -1430,10 +1430,9 @@ public class WorkflowExecuteThread implements Runnable {
                         this.processInstance.getId());
                 taskResponseService.addResponse(taskResponseEvent);
             }
+            this.taskRetryCheckList.remove(taskId);
+            this.depStateCheckList.remove(taskId);
         }
-
-        this.taskRetryCheckList.clear();
-        this.depStateCheckList.clear();
         this.addProcessStopEvent(processInstance);
     }