From d0366082e604bb4624d0b90e27ea1b044a8a2b3b Mon Sep 17 00:00:00 2001
From: JinYong Li <42576980+JinyLeeChina@users.noreply.github.com>
Date: Mon, 10 Oct 2022 16:15:17 +0800
Subject: [PATCH] [Fix-12167][MasterServer] The retry task was submitted in
 advance (#12291)

Co-authored-by: JinyLeeChina <jiny.li@foxmail.com>
---
 .../server/master/runner/WorkflowExecuteThread.java           | 4 ++++
 1 file changed, 4 insertions(+)

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