-
Notifications
You must be signed in to change notification settings - Fork 556
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
Notify checkpoint listeners after init and replay #9943
Conversation
Test Results 799 files + 2 1 errors 798 suites +2 1h 35m 14s ⏱️ - 1m 15s For more details on these parsing errors, see this check. Results for commit afa7f09. ± Comparison against base commit c7debcc. ♻️ This comment has been updated with latest results. |
The listeners must be updated with the current checkpointId after init and replay. Otherwise if there are no new checkpoint created, after a restart or failover the listeners cannot know about the latest checkpoint. It is important for `InterPartitionCommandSender` and `InterPartitionCommandReceiver` to keep track of the latest checkpointId to guarantee that the checkpoints are consistent.
a71c706
to
e0198f7
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.
Looks good, except that I think that we need to call the listener on register.
backup/src/main/java/io/camunda/zeebe/backup/processing/CheckpointRecordsProcessor.java
Show resolved
Hide resolved
backup/src/main/java/io/camunda/zeebe/backup/api/CheckpointListener.java
Show resolved
Hide resolved
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.
Awesome 🚀
bors merge |
Build succeeded: |
Description
The listeners must be upddated with the current checkpointId after init and replay. Otherwise if there are no new checkpoint created, after a restart or failover the listeners cannot know about the latest checkpoint. It is important for
InterPartitionCommandSencer
andInterPartitionCommandReceiver
to keep track of the latest checkpointId to guarantee that the checkpoints are consistent.Related issues
closes #9916
Definition of Done
Not all items need to be done depending on the issue and the pull request.
Code changes:
backport stable/1.3
) to the PR, in case that fails you need to create backports manually.Testing:
Documentation:
Please refer to our review guidelines.