From 8d39bf14b1b189b43d27acfa2a3ae9ddd4eec5c6 Mon Sep 17 00:00:00 2001 From: SbloodyS <460888207@qq.com> Date: Sun, 5 Dec 2021 13:52:48 +0800 Subject: [PATCH] [Fix-7093][dolphincheduler-server] fix dependent node stuck in running (#7116) * fix bug 7093 * remove redundant else Co-authored-by: SbloodyS --- .../server/master/runner/StateWheelExecuteThread.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/StateWheelExecuteThread.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/StateWheelExecuteThread.java index 69bd3cb4ad..84db5bcb10 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/StateWheelExecuteThread.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/StateWheelExecuteThread.java @@ -92,9 +92,8 @@ public class StateWheelExecuteThread extends Thread { for (TaskInstance taskInstance : this.taskInstanceCheckList.values()) { if (TimeoutFlag.OPEN == taskInstance.getTaskDefine().getTimeoutFlag()) { long timeRemain = DateUtils.getRemainTime(taskInstance.getStartTime(), taskInstance.getTaskDefine().getTimeout() * Constants.SEC_2_MINUTES_TIME_UNIT); - if (0 <= timeRemain && processTimeout(taskInstance)) { + if (0 >= timeRemain && processTimeout(taskInstance)) { taskInstanceCheckList.remove(taskInstance.getId()); - return; } } if (taskInstance.taskCanRetry() && taskInstance.retryTaskIntervalOverTime()) {