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

SingleLogicalSlot returns completed release future before slot is properly returned

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Blocker
    • Resolution: Fixed
    • 1.5.0, 1.6.0
    • 1.5.0
    • Runtime / Coordination

    Description

      The SingleLogicalSlot#releaseSlot method returns a future which is completed once the slot has been returned to the SlotOwner. Unfortunately, we don't wait for the SlotOwner's response to complete the future but complete it directly after the call has been made. This causes that the ExecutionGraph can get restarted in case of a recovery before all of its slots have been returned to the SlotPool. As a consequence, the allocation of the new tasks might require more than the max parallelism because of collisions with old tasks (in case of slot sharing).

      Attachments

        Issue Links

          Activity

            People

              trohrmann Till Rohrmann
              trohrmann Till Rohrmann
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: