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

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

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Blocker
    • Resolution: Fixed
    • Affects Version/s: 1.2.0, 1.2.1, 1.3.0, 1.3.1, 1.3.2, 1.4.0
    • Fix Version/s: 1.4.1, 1.5.0
    • Component/s: Network
    • Labels:
      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

            • Assignee:
              NicoK Nico Kruber
              Reporter:
              NicoK Nico Kruber
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: