[ https://issues.apache.org/jira/browse/FLINK-8371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Nico Kruber closed FLINK-8371. ------------------------------ Resolution: Fixed Fix Version/s: 1.4.1 Merged. 1.5.0: 4c3f6075bcad0e85db947d7db7817a678d21a85e 1.4.1: 71ede3992afe8f6907dd3c6c1e232c5b745048b4 > 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 > Fix For: 1.5.0, 1.4.1 > > > {{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)