Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-26079

[Changelog] Disallow recovery from non-changelog checkpoints

    XMLWordPrintableJSON

Details

    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

          Activity

            People

              roman Roman Khachatryan
              roman Roman Khachatryan
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: