branch-2.1: [improve](routine load) ensure load balance after scaling…

… up BE nodes #44693 (#44799) Cherry-picked from #44693 Co-authored-by: hui lai <[email protected]>
apache · Dec 2, 2024 · 8843b17 · 8843b17
1 parent 54e2249
commit 8843b17
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -486,6 +486,7 @@ public long getAvailableBeForTask(long jobId, long previousBeId) throws LoadExce
         // check if be has idle slot
         readLock();
         try {
+            updateBeIdToMaxConcurrentTasks();
             Map<Long, Integer> beIdToConcurrentTasks = getBeCurrentTasksNumMap();
             int previousBeIdleTaskNum = 0;