Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-12069 Add proper lifecycle management for intermediate result partitions
  3. FLINK-12616

Maintain connection between JM<->TM until all partitions have been released

    XMLWordPrintableJSON

    Details

    • Type: Sub-task
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.9.0
    • Component/s: Runtime / Coordination
    • Labels:
      None

      Description

      Currently, the connection between JM and TM are kept open until all slots allocated by the JM on the TM have been released.
      We have to extend this logic to also take partitions into account, such that partitions remain accessible to the JM, even if no slots are allocated.

        Attachments

          Activity

            People

            • Assignee:
              chesnay Chesnay Schepler
              Reporter:
              chesnay Chesnay Schepler
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: