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

zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new f78ef9ec08 [Fix-13815][master] Fix dependent task incorrect timeout 
alerts (#13822)
f78ef9ec08 is described below

commit f78ef9ec08d62b575846236a127a13eb3b460a60
Author: ralphgj <[email protected]>
AuthorDate: Wed Apr 19 16:14:13 2023 +0800

    [Fix-13815][master] Fix dependent task incorrect timeout alerts (#13822)
---
 .../server/master/runner/StateWheelExecuteThread.java                 | 4 ----
 1 file changed, 4 deletions(-)

diff --git 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/StateWheelExecuteThread.java
 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/StateWheelExecuteThread.java
index 90ce4ff00e..fc171e4ccc 100644
--- 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/StateWheelExecuteThread.java
+++ 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/StateWheelExecuteThread.java
@@ -184,10 +184,6 @@ public class StateWheelExecuteThread extends 
BaseDaemonThread {
             taskInstanceTimeoutCheckList.add(taskInstanceKey);
             log.info("Timeout flag is open, added task instance into timeout 
check list");
         }
-        if (taskInstance.isDependTask() || taskInstance.isSubProcess()) {
-            taskInstanceTimeoutCheckList.add(taskInstanceKey);
-            log.info("task instance is dependTask orSubProcess, added task 
instance into timeout check list");
-        }
     }
 
     public void removeTask4TimeoutCheck(@NonNull ProcessInstance 
processInstance, @NonNull TaskInstance taskInstance) {

Reply via email to