Weijie Guo created FLINK-33076:
----------------------------------

             Summary: broadcastEmit of ChannelSelectorRecordWriter should reuse 
the serialized record
                 Key: FLINK-33076
                 URL: https://issues.apache.org/jira/browse/FLINK-33076
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Network
            Reporter: Weijie Guo
            Assignee: Weijie Guo


ChannelSelectorRecordWriter#broadcastEmit serialize the record to ByteBuffer 
but didn't use it. It will re-serialize this record per-channel. We should 
allows all channels to reuse the serialized buffer.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to