Ted Yu created FLINK-9087: ----------------------------- Summary: Return value of broadcastEvent should be closed in StreamTask#performCheckpoint Key: FLINK-9087 URL: https://issues.apache.org/jira/browse/FLINK-9087 Project: Flink Issue Type: Bug Reporter: Ted Yu
{code} for (StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>> streamRecordWriter : streamRecordWriters) { try { streamRecordWriter.broadcastEvent(message); {code} The BufferConsumer returned by broadcastEvent() should be closed. -- This message was sent by Atlassian JIRA (v7.6.3#76005)