(flink) branch master updated: [FLINK-38943][runtime] Avoid duplicate serialization in adaptive broadcast (#28135)

[panyuepeng]

This is an automated email from the ASF dual-hosted git repository.

RocMarshal pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 81ae794b0c9 [FLINK-38943][runtime] Avoid duplicate serialization in 
adaptive broadcast (#28135)
81ae794b0c9 is described below

commit 81ae794b0c90821756e21924d81fe7719dbb9689
Author: big face cat <731030...@qq.com>
AuthorDate: Sun May 10 18:37:09 2026 +0800

    [FLINK-38943][runtime] Avoid duplicate serialization in adaptive broadcast 
(#28135)
    
    Co-authored-by: Yuepeng Pan <hipanyuep...@gmail.com>
---
 .../runtime/io/network/api/writer/AdaptiveLoadBasedRecordWriter.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/AdaptiveLoadBasedRecordWriter.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/AdaptiveLoadBasedRecordWriter.java
index 19eb08e6571..3b94014c29a 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/AdaptiveLoadBasedRecordWriter.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/AdaptiveLoadBasedRecordWriter.java
@@ -129,7 +129,7 @@ public final class AdaptiveLoadBasedRecordWriter<T extends 
IOReadableWritable>
         ByteBuffer serializedRecord = serializeRecord(serializer, record);
         for (int channelIndex = 0; channelIndex < numberOfSubpartitions; 
channelIndex++) {
             serializedRecord.rewind();
-            emit(record, channelIndex);
+            emit(serializedRecord, channelIndex);
         }
 
         if (flushAlways) {