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)