-
Notifications
You must be signed in to change notification settings - Fork 1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
sharding snapshot & journal cleanup #2703
sharding snapshot & journal cleanup #2703
Conversation
77aeb4a
to
dc0d62c
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This PR looks good, but string format for new logs is incorrect (akka on jvm uses {}
but akka.net requires argument indexing like {0}
).
} | ||
break; | ||
case SaveSnapshotFailure m: | ||
Log.Warning("PersistentShard snapshot failure: {}", m.Cause.Message); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
In .NET logging we must provide index for arguments. So {}
itself will fail, you need to use {0}
, {1}
and so on.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Right, completely overlooked that. Fixed
dc0d62c
to
96ff40c
Compare
Log.Debug("PersistentShard snapshots matching {0} deleted successfully", m.Criteria); | ||
break; | ||
case DeleteSnapshotsFailure m: | ||
Log.Warning("PersistentShard snapshots matching {0} deletion falure: {1}", m.Criteria, m.Cause.Message); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Should be failure
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
fixed
@zbynek001 You have also implemented this issue |
I think that's obsolete code. |
96ff40c
to
32deffd
Compare
port of
akka/akka#21725
akka/akka#22916