From f78ef9ec08d62b575846236a127a13eb3b460a60 Mon Sep 17 00:00:00 2001 From: ralphgj Date: Wed, 19 Apr 2023 16:14:13 +0800 Subject: [PATCH] [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) {