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 8843b17a28d branch-2.1: [improve](routine load) ensure load balance
after scaling up BE nodes #44693 (#44799)
8843b17a28d is described below
commit 8843b17a28de67fbe8d2562d224de3aceef2ffe0
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Dec 2 15:04:11 2024 +0800
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]>
---
.../main/java/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 6121f34035c..c4cb6119e94 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<Long, Integer> beIdToConcurrentTasks =
getBeCurrentTasksNumMap();
int previousBeIdleTaskNum = 0;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
