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

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • 1.9.0
    • Runtime / Coordination
    • 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

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

            Dates

              Created:
              Updated:
              Resolved: