diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2021-01-26 15:32:47 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2021-01-26 15:32:47 +0300 |
| commit | c15024844d26a6d16b5f40b5727213e0a11372d5 (patch) | |
| tree | 074fff9ac68cc63658cb37f25318abfd3c43fc41 | |
| parent | 429f87913e1f81a635777c6ae8a8168c57764b9c (diff) | |
| download | rabbitmq-server-git-c15024844d26a6d16b5f40b5727213e0a11372d5.tar.gz | |
rabbit_amqqueue:maybe_rebalance/4: only consider nodes not under maintenance
| -rw-r--r-- | deps/rabbit/src/rabbit_amqqueue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/deps/rabbit/src/rabbit_amqqueue.erl b/deps/rabbit/src/rabbit_amqqueue.erl index 2f628101d9..f79c7592cc 100644 --- a/deps/rabbit/src/rabbit_amqqueue.erl +++ b/deps/rabbit/src/rabbit_amqqueue.erl @@ -436,7 +436,7 @@ rebalance(Type, VhostSpec, QueueSpec) -> maybe_rebalance({true, Id}, Type, VhostSpec, QueueSpec) -> rabbit_log:info("Starting queue rebalance operation: '~s' for vhosts matching '~s' and queues matching '~s'", [Type, VhostSpec, QueueSpec]), - Running = rabbit_nodes:all_running(), + Running = rabbit_maintenance:filter_out_drained_nodes_consistent_read(rabbit_nodes:all_running()), NumRunning = length(Running), ToRebalance = [Q || Q <- rabbit_amqqueue:list(), filter_per_type(Type, Q), |