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) {