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 518ccbb035..04d4dc5621 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 @@ -183,10 +183,7 @@ public class StateWheelExecuteThread extends BaseDaemonThread { taskInstanceTimeoutCheckList.add(taskInstanceKey); logger.info("Timeout flag is open, added task instance into timeout check list"); } - if (taskInstance.isDependTask() || taskInstance.isSubProcess()) { - taskInstanceTimeoutCheckList.add(taskInstanceKey); - logger.info("task instance is dependTask orSubProcess, added task instance into timeout check list"); - } + } public void removeTask4TimeoutCheck(@NonNull ProcessInstance processInstance, @NonNull TaskInstance taskInstance) {