diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadManager.java b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadManager.java index 6121f34035..c4cb6119e9 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadManager.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadManager.java @@ -486,6 +486,7 @@ public class RoutineLoadManager implements Writable { // check if be has idle slot readLock(); try { + updateBeIdToMaxConcurrentTasks(); Map beIdToConcurrentTasks = getBeCurrentTasksNumMap(); int previousBeIdleTaskNum = 0;