branch-2.1: [fix](routine load) fix invalid EOF tasks scheduling delay …

…apache#44949 (apache#45088) Cherry-picked from apache#44949 Co-authored-by: hui lai <[email protected]>
seawinde · Dec 6, 2024 · 3018e9a · 3018e9a
1 parent 08c8a41
commit 3018e9a
Showing 1 changed file with 1 addition and 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
@@ -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;
                 }