From c6bac64fab8efbc91fe28bd7b79e75b52f7db978 Mon Sep 17 00:00:00 2001
From: laihui <laihui@selectdb.com>
Date: Thu, 28 Nov 2024 16:27:11 +0800
Subject: [PATCH] ensure load balance after scaling up BE nodes

---
 .../org/apache/doris/load/routineload/RoutineLoadManager.java    | 1 +
 1 file changed, 1 insertion(+)

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 8b0ebab3fbe7d5..97f6aba8c589c6 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
@@ -487,6 +487,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;