diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2022-10-25 13:27:07 +0400 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2022-10-25 13:27:07 +0400 |
| commit | 81daaf7a9aa61504523cfa9266999a64ca971549 (patch) | |
| tree | 649388e7eb0b673af60678cee9677cca0b44510c | |
| parent | 6f6e4b1acd8d59a63503347a076e8805893616da (diff) | |
| download | rabbitmq-server-git-81daaf7a9aa61504523cfa9266999a64ca971549.tar.gz | |
Wording
| -rw-r--r-- | deps/rabbit/src/rabbit_stream_coordinator.erl | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/deps/rabbit/src/rabbit_stream_coordinator.erl b/deps/rabbit/src/rabbit_stream_coordinator.erl index f6aaa9d2c4..d10aa1c7b2 100644 --- a/deps/rabbit/src/rabbit_stream_coordinator.erl +++ b/deps/rabbit/src/rabbit_stream_coordinator.erl @@ -1753,8 +1753,8 @@ fail_active_actions(Streams, Exclude) -> end, Members), case Mnesia of {updating, E} -> - rabbit_log:debug("~ts: failing active action for ~ts node - ~w Action ~w", + rabbit_log:debug("~ts: schema database action failed, will have to retry. " + "Stream ID: ~ts, node: ~w, action: ~w", [?MODULE, Id, node(), updating_mnesia]), send_self_command({action_failed, Id, #{action => updating_mnesia, @@ -1774,8 +1774,9 @@ fail_action(_StreamId, #member{current = undefined}) -> fail_action(StreamId, #member{role = {_, E}, current = {Action, Idx}, node = Node}) -> - rabbit_log:debug("~ts: failing active action for ~ts node ~w Action ~w", - [?MODULE, StreamId, Node, Action]), + rabbit_log:debug("~ts: schema database action failed, will have to retry. " + "Stream ID: ~ts, node: ~w, action: ~w", + [?MODULE, StreamId, node(), updating_mnesia]), %% if we have an action send failure message send_self_command({action_failed, StreamId, #{action => Action, |