diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/base/JobExecutionConfiguration.java b/fe/fe-core/src/main/java/org/apache/doris/job/base/JobExecutionConfiguration.java index 73196bfc086ee31..4c6ef4d2037f86c 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/job/base/JobExecutionConfiguration.java +++ b/fe/fe-core/src/main/java/org/apache/doris/job/base/JobExecutionConfiguration.java @@ -171,7 +171,7 @@ private List getExecutionDelaySeconds(long windowStartTimeMs, long windowE long firstTriggerTime = windowStartTimeMs + (intervalMs - ((windowStartTimeMs - startTimeMs) % intervalMs)) % intervalMs; - if (firstTriggerTime <= currentTimeMs) { + if (firstTriggerTime < currentTimeMs) { // Calculate how many intervals to add to get the largest trigger time < currentTimeMs long intervalsToAdd = (currentTimeMs - firstTriggerTime) / intervalMs; firstTriggerTime += intervalsToAdd * intervalMs;