Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25842 [v2] FLIP-158: Generalized incremental checkpoints
  3. FLINK-23343

State ownership: prevent shared state deletion on TM

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Won't Fix
    • None
    • 1.16.0
    • Runtime / State Backends
    • None

    Description

      Inject shared state IDs computed in StateAssignmentOperation (FLINK-23342) into Task StateRegistry (FLINK-23139) and prevent their deletion.

      See https://docs.google.com/document/d/1NJJQ30P27BmUvD7oa4FChvkYxMEgjRPTVdO1dHLl_9I/edit#heading=h.uednun2snp4l for more details

      Attachments

        Issue Links

          is blocked by

          Sub-task - The sub-task of the issue FLINK-23139 State ownership: track and discard private state (registry+changelog)

          • Major - Major loss of function.
          • Closed

          Sub-task - The sub-task of the issue FLINK-23342 State ownership: compute shared state on recovery

          • Major - Major loss of function.
          • Closed

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: