[dolphinscheduler] branch 2.0.6-prepare updated: [Fix-10443][server]fix dependent task always running (#10708)

[ji...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jinyleechina pushed a commit to branch 2.0.6-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/2.0.6-prepare by this push:
     new 520e72f3de [Fix-10443][server]fix dependent task always running (#10708)
520e72f3de is described below

commit 520e72f3de333ccee684351b9212148fb0110b4e
Author: weeway <ge...@gmail.com>
AuthorDate: Fri Jul 1 17:21:26 2022 +0800

    [Fix-10443][server]fix dependent task always running (#10708)
    
    * [Fix-10443][server]fix dependent task always running
    
    * optimize remove logic
---
 .../dolphinscheduler/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);
     }