Skip to content

Commit

Permalink
[improve](routine load) ensure load balance after scaling up BE nodes (
Browse files Browse the repository at this point in the history
…#44693)

We scaling up from three BE nodes to five BE nodes, but from the
monitoring perspective, only the previous three nodes have written
traffic.

![image](https://github.com/user-attachments/assets/947fe8a9-745d-4c37-93d4-15b0e27f12fc)

This pr aims to ensure load balance after scaling up BE nodes.
  • Loading branch information
sollhui authored Nov 29, 2024
1 parent 851d780 commit fed46d2
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down

0 comments on commit fed46d2

Please sign in to comment.