[FLINK-32698] Add getCheckpointOptions interface in ManagedSnapshotContext

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Runtime / Checkpointing
• Assignee: Unassigned
• Reporter: Ming Li
• Created: 27/Jul/23 03:40
• Updated: 27/Jul/23 06:20

Description

Currently only checkpointID and checkpointTimestamp information are provided in ManagedSnapshotContext. We hope to provide more information about CheckpointOptions, so that operators can adopt different logics when performing SnapshotState.

 

An example is to adopt different behaviors according to the type of checkpoint. For example, in Paimon, we hope that the paimon‘s snapshot written by checkpoint can expire automatically, while the paimon‘s snapshot written by savepoint can be persisted.