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

Buffers are not recycled in a non-spilled SpillableSubpartition upon release

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Blocker
    • Resolution: Fixed
    • 1.2.0, 1.2.1, 1.3.0, 1.3.1, 1.3.2, 1.4.0
    • 1.4.1, 1.5.0
    • Runtime / Network
    • None

    Description

      SpillableSubpartition only recycles buffers in its buffer queue if there is no view attached to it yet. If there is a view, it delegates this task to the view, but SpillableSubpartitionView only instructs the SpilledSubpartitionView to clean up in its releaseAllResources().

      Similarly to the PipelinesSubpartition implementation, we should always clean up and recycle the buffers in SpillableSubpartition#release().

      Attachments

        Activity

          People

            nkruber Nico Kruber
            nkruber Nico Kruber
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: