You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
9891: Send current checkpoint id with inter-partition commands r=oleschoenburg a=oleschoenburg
## Description
The sender implements a `CheckpointListener`, updating an internalfield whenever a new checkpoint is created. For all commands, the current checkpoint id is sent along.
The sender is no longer thread-safe. Calls of the listener and the send methods must be linearized by the stream processor, otherwise commands could be sent with stale checkpoint ids.
## Related issues
<!-- Which issues are closed by this PR or are related -->
closes#9810
Co-authored-by: Ole Schönburg <ole.schoenburg@gmail.com>
9891: Send current checkpoint id with inter-partition commands r=oleschoenburg a=oleschoenburg
## Description
The sender implements a `CheckpointListener`, updating an internalfield whenever a new checkpoint is created. For all commands, the current checkpoint id is sent along.
The sender is no longer thread-safe. Calls of the listener and the send methods must be linearized by the stream processor, otherwise commands could be sent with stale checkpoint ids.
## Related issues
<!-- Which issues are closed by this PR or are related -->
closes#9810
Co-authored-by: Ole Schönburg <ole.schoenburg@gmail.com>
Every message send between partitions must encode the current checkpointId at the sender.
Depends on #9720 #9625 #9721
The text was updated successfully, but these errors were encountered: