[ https://issues.apache.org/jira/browse/FLINK-8371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16313498#comment-16313498 ]
Nico Kruber commented on FLINK-8371: ------------------------------------ Working on it - also, while doing so, I noticed that similarly, {{SpillableSubpartitionView#nextBuffer}} is also not cleaned up (if populated when the {{release()}} is happening). > Buffers are not recycled in a non-spilled SpillableSubpartition upon release > ---------------------------------------------------------------------------- > > Key: FLINK-8371 > URL: https://issues.apache.org/jira/browse/FLINK-8371 > Project: Flink > Issue Type: Bug > Components: Network > Affects Versions: 1.2.0, 1.3.0, 1.2.1, 1.3.1, 1.4.0, 1.3.2 > Reporter: Nico Kruber > Assignee: Nico Kruber > Priority: Blocker > > {{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()}}. -- This message was sent by Atlassian JIRA (v6.4.14#64029)