This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 3018e9af4c7 branch-2.1: [fix](routine load) fix invalid EOF tasks
scheduling delay #44949 (#45088)
3018e9af4c7 is described below
commit 3018e9af4c7d83073e5a9555fd591e4eeba1dc02
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Dec 6 17:01:17 2024 +0800
branch-2.1: [fix](routine load) fix invalid EOF tasks scheduling delay
#44949 (#45088)
Cherry-picked from #44949
Co-authored-by: hui lai <[email protected]>
---
.../org/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 8afc35411b5..d40a6705626 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 @@ public class RoutineLoadTaskScheduler extends MasterDaemon {
if (routineLoadTaskInfo.getIsEof()) {
RoutineLoadJob routineLoadJob =
routineLoadManager.getJob(routineLoadTaskInfo.getJobId());
if (System.currentTimeMillis() -
routineLoadTaskInfo.getLastScheduledTime()
- < routineLoadJob.getMaxBatchIntervalS()) {
+ < routineLoadJob.getMaxBatchIntervalS() * 1000) {
needScheduleTasksQueue.addLast(routineLoadTaskInfo);
return;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
