[FLINK-23441] Remove CheckpointOptions Argument away from Snapshotable#snapshot

• Type: Improvement
• Status: In Progress
• Priority: Major
• Resolution: Unresolved
• Component/s: Runtime / State Backends
• Labels: pull-request-available stale-assigned
• Assignee: Yuan Mei
• Reporter: Yuan Mei
• Created: 21/Jul/21 02:28
• Updated: 08/Oct/21 11:28

Description

CheckpointOptions contain many fields that are not related to the backend snapshot (materialization in changelog):

alignment type, alignedCheckpointTimeout, and even CheckpointStorageLocationReference

(the location is provided by/included in the #StreamFactory# already, we do not use CheckpointStorageLocationReference in away place in snapshotting.

=================================

In the future, if we want to separate checkpointing away from materialization (conceptually, they are indeed two different pieces as well), we do not need to provide such CheckpointOptions for each snapshotting.

 

 

 

Issue Links

• relates to: FLINK-21352 FLIP-158: Generalized incremental checkpoints
• links to: GitHub Pull Request #16548