diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java index ae837dfe86..b90453349f 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java @@ -1464,6 +1464,10 @@ public class WorkflowExecuteThread implements Runnable { submitPostNode(Long.toString(task.getTaskCode())); continue; } + if (retryTask != null && !retryTask.retryTaskIntervalOverTime()) { + logger.info("task name: {} retry waiting has not exceeded the interval time, and skip submission this time, task id:{}", task.getName(), task.getId()); + continue; + } } //init varPool only this task is the first time running if (task.isFirstRun()) {