Details
-
Bug
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
None
Description
Extracted from FLINK-25872.
The issue is with the CLAIM mode:
> Because discarding an initial checkpoint will invalidate its "private" state which might be in use by future checkpoints.
> Normally, changelog backend wraps it and registers with tjhe SharedStateRegistry.
> But when recovering from non-changelog checkpoint, it is first added to the Checkpoint store, and wrapping in subsequent checkpoints doesn't help.
NO_CLAIM mode is not supported.
LEGACY could work.
But it's difficult to differentiate between the modes on TM, where backend type is reliably known (see the discussion below).
CANONICAL non-changelog savepoints must still be supported.
Attachments
Issue Links
- blocks
-
FLINK-21352 FLIP-158: Generalized incremental checkpoints
- Resolved
- is caused by
-
FLINK-25872 Restoring from non-changelog checkpoint with changelog state-backend enabled in CLAIM mode discards state in use
- Closed
- links to