diff options
| author | Michael Klishin <klishinm@vmware.com> | 2021-11-03 14:12:27 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-11-03 14:12:27 +0300 |
| commit | 8827d5197b407f28cd856e237c9bbdd098a250a8 (patch) | |
| tree | 443e1e3ee948e2838c690e3eb1c6b7d071f2201e | |
| parent | 5dd8c7fe4dc3a71943fa70471492efa82bfb4b4d (diff) | |
| parent | 3f8925954cf33c5a9bcab8723b4f1a97c1730d2d (diff) | |
| download | rabbitmq-server-git-8827d5197b407f28cd856e237c9bbdd098a250a8.tar.gz | |
Merge pull request #3643 from rabbitmq/rebalance-logging
Turn down logging from queue rebalancing
| -rw-r--r-- | deps/rabbit/src/rabbit_amqqueue.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/deps/rabbit/src/rabbit_amqqueue.erl b/deps/rabbit/src/rabbit_amqqueue.erl index 1706ca434c..96db3bac07 100644 --- a/deps/rabbit/src/rabbit_amqqueue.erl +++ b/deps/rabbit/src/rabbit_amqqueue.erl @@ -511,11 +511,11 @@ maybe_migrate(ByNode, MaxQueuesDesired, [N | Nodes]) -> {not_migrated, update_not_migrated_queue(N, Queue, Queues, ByNode)}; _ -> [{Length, Destination} | _] = sort_by_number_of_queues(Candidates, ByNode), - rabbit_log:warning("Migrating queue ~p from node ~p with ~p queues to node ~p with ~p queues", + rabbit_log:info("Migrating queue ~p from node ~p with ~p queues to node ~p with ~p queues", [Name, N, length(All), Destination, Length]), case Module:transfer_leadership(Q, Destination) of {migrated, NewNode} -> - rabbit_log:warning("Queue ~p migrated to ~p", [Name, NewNode]), + rabbit_log:info("Queue ~p migrated to ~p", [Name, NewNode]), {migrated, update_migrated_queue(Destination, N, Queue, Queues, ByNode)}; {not_migrated, Reason} -> rabbit_log:warning("Error migrating queue ~p: ~p", [Name, Reason]), @@ -527,7 +527,7 @@ maybe_migrate(ByNode, MaxQueuesDesired, [N | Nodes]) -> "Do nothing", [N, length(All)]), maybe_migrate(ByNode, MaxQueuesDesired, Nodes); All -> - rabbit_log:warning("Node ~p only contains ~p queues, do nothing", + rabbit_log:debug("Node ~p only contains ~p queues, do nothing", [N, length(All)]), maybe_migrate(ByNode, MaxQueuesDesired, Nodes) end. |