Ted Yu created FLINK-9223: ----------------------------- Summary: bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd Key: FLINK-9223 URL: https://issues.apache.org/jira/browse/FLINK-9223 Project: Flink Issue Type: Test Reporter: Ted Yu
{code} BufferConsumer[] bufferConsumers = Arrays.stream(bufferBuilders).map( BufferBuilder::createBufferConsumer ).toArray(BufferConsumer[]::new); {code} After operation on bufferConsumers is done, the BufferConsumer's in the array should be closed. -- This message was sent by Atlassian JIRA (v7.6.3#76005)