[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16433814#comment-16433814 ]
ASF GitHub Bot commented on FLINK-9087: --------------------------------------- Github user zentol commented on the issue: https://github.com/apache/flink/pull/5802 merging. > Change the method signature of RecordWriter#broadcastEvent() from > BufferConsumer to void > ---------------------------------------------------------------------------------------- > > Key: FLINK-9087 > URL: https://issues.apache.org/jira/browse/FLINK-9087 > Project: Flink > Issue Type: Bug > Components: Network > Affects Versions: 1.5.0, 1.6.0 > Reporter: Ted Yu > Priority: Minor > > {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)