diff options
| author | Karl Nilsson <kjnilsson@gmail.com> | 2022-10-25 11:18:21 +0100 |
|---|---|---|
| committer | Karl Nilsson <kjnilsson@gmail.com> | 2022-10-25 11:18:21 +0100 |
| commit | fdad0e99b199c1d936dba0cc023f0f0c7e8379db (patch) | |
| tree | 3c66a5d0423eea864cdded2cb274c221771e5cc4 | |
| parent | 2c0290c6ba343769b86b1158363454fd65b53094 (diff) | |
| download | rabbitmq-server-git-fdad0e99b199c1d936dba0cc023f0f0c7e8379db.tar.gz | |
Stream coordinator: reword some log messages
To be more precise of the status of actions that need to be failed
at leader change.
| -rw-r--r-- | deps/rabbit/src/rabbit_stream_coordinator.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/deps/rabbit/src/rabbit_stream_coordinator.erl b/deps/rabbit/src/rabbit_stream_coordinator.erl index d10aa1c7b2..8e5414f7f5 100644 --- a/deps/rabbit/src/rabbit_stream_coordinator.erl +++ b/deps/rabbit/src/rabbit_stream_coordinator.erl @@ -1753,7 +1753,7 @@ fail_active_actions(Streams, Exclude) -> end, Members), case Mnesia of {updating, E} -> - rabbit_log:debug("~ts: schema database action failed, will have to retry. " + rabbit_log:debug("~ts: failing stale action to trigger retry. " "Stream ID: ~ts, node: ~w, action: ~w", [?MODULE, Id, node(), updating_mnesia]), send_self_command({action_failed, Id, @@ -1774,9 +1774,9 @@ fail_action(_StreamId, #member{current = undefined}) -> fail_action(StreamId, #member{role = {_, E}, current = {Action, Idx}, node = Node}) -> - rabbit_log:debug("~ts: schema database action failed, will have to retry. " + rabbit_log:debug("~ts: failing stale action to trigger retry. " "Stream ID: ~ts, node: ~w, action: ~w", - [?MODULE, StreamId, node(), updating_mnesia]), + [?MODULE, StreamId, node(), Action]), %% if we have an action send failure message send_self_command({action_failed, StreamId, #{action => Action, |