(flink) branch release-2.3 updated: [FLINK-38943][runtime] Avoid duplicate serialization in adaptive broadcast (#28139)

[panyuepeng]

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

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


The following commit(s) were added to refs/heads/release-2.3 by this push:
     new 912289be76d [FLINK-38943][runtime] Avoid duplicate serialization in 
adaptive broadcast (#28139)
912289be76d is described below

commit 912289be76d9c9dd3f29b199680e4840add27556
Author: big face cat <731030...@qq.com>
AuthorDate: Wed Jun 17 11:13:21 2026 +0800

    [FLINK-38943][runtime] Avoid duplicate serialization in adaptive broadcast 
(#28139)
    
    (cherry picked from commit 81ae794b0c90821756e21924d81fe7719dbb9689)
    
    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) {