Notify CheckpointListeners after init and replay #9916
Labels
kind/toil
Categorizes an issue or PR as general maintenance, i.e. cleanup, refactoring, etc.
version:8.1.0-alpha5
Marks an issue as being completely or in parts released in 8.1.0-alpha5
version:8.1.0
Marks an issue as being completely or in parts released in 8.1.0
Description
InterpartitionCommandSender and Reciever keeps track of the latest checkpointId via CheckpointListeners. We must ensure that they have the correct valued even after failovers or restart. Currently CheckpointListeners are notified only when checkpoint record is processed. In addition, they should be notified after the processor initializes it's state, when a new listener is registerd, and CREATED record is replayed.
Ref:- #9899 (comment)
The text was updated successfully, but these errors were encountered: