Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-36200 Breaking changes for Flink 3.0
  3. FLINK-5337

Introduce backwards compatible state to task assignment

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Open
    • Minor
    • Resolution: Unresolved
    • None
    • 3.0.0
    • Runtime / State Backends
    • None

    Description

      Flink assigns state to tasks through either a) user defined uids or b) uids generated through hashing certain properties of the StreamingJobGraph.

      While method a) is backwards compatible, it can be tedious for the user. Method b) easily breaks w.r.t. backwards compatibility under any changes to graph generation, e.g. when removing chaining.

      We should think about a backwards compatible way assigning state to tasks, that hopefully works without explicit uid assignment by the user.

      Attachments

        Activity

          People

            Unassigned Unassigned
            srichter Stefan Richter
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated: