Skip to content

Commit 81bf8f3

Browse files
Merge pull request #2993 from rabbitmq/rebalance-ignore-drained
Ignore drained nodes when rebalancing (cherry picked from commit bedc46a)
1 parent a728662 commit 81bf8f3

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

deps/rabbit/src/rabbit_amqqueue.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -596,7 +596,7 @@ maybe_migrate(ByNode, MaxQueuesDesired, [N | Nodes]) ->
596596
[{_, Q, false} = Queue | Queues] = All when length(All) > MaxQueuesDesired ->
597597
Name = amqqueue:get_name(Q),
598598
Module = rebalance_module(Q),
599-
Candidates = Module:get_replicas(Q) -- [N],
599+
Candidates = rabbit_maintenance:filter_out_drained_nodes_local_read(Module:get_replicas(Q) -- [N]),
600600
case Candidates of
601601
[] ->
602602
{not_migrated, update_not_migrated_queue(N, Queue, Queues, ByNode)};

0 commit comments

Comments
 (0)