From 0525ed7d2851b762266956c97e33a961f36a8e47 Mon Sep 17 00:00:00 2001
From: "github-actions[bot]"
 <41898282+github-actions[bot]@users.noreply.github.com>
Date: Fri, 6 Dec 2024 19:09:27 +0800
Subject: [PATCH] branch-3.0: [fix](routine load) fix invalid EOF tasks
 scheduling delay #44949 (#45087)

Cherry-picked from #44949

Co-authored-by: hui lai <laihui@selectdb.com>
---
 .../apache/doris/load/routineload/RoutineLoadTaskScheduler.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadTaskScheduler.java b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadTaskScheduler.java
index 8afc35411b55f5..d40a6705626c84 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadTaskScheduler.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadTaskScheduler.java
@@ -106,7 +106,7 @@ private void process() throws UserException, InterruptedException {
             if (routineLoadTaskInfo.getIsEof()) {
                 RoutineLoadJob routineLoadJob = routineLoadManager.getJob(routineLoadTaskInfo.getJobId());
                 if (System.currentTimeMillis() - routineLoadTaskInfo.getLastScheduledTime()
-                        < routineLoadJob.getMaxBatchIntervalS()) {
+                        < routineLoadJob.getMaxBatchIntervalS() * 1000) {
                     needScheduleTasksQueue.addLast(routineLoadTaskInfo);
                     return;
                 }