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)