(inlong) branch master updated: [INLONG-11434][DataProxy] Fix the message body of msgType=5 is incorrect (#11435)

[dockerzhang]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new b841be110c [INLONG-11434][DataProxy] Fix the message body of msgType=5 
is incorrect (#11435)
b841be110c is described below

commit b841be110c641a737bafc6db5fc269ffb2f2342e
Author: Goson Zhang <4675...@qq.com>
AuthorDate: Tue Oct 29 22:49:00 2024 +0800

    [INLONG-11434][DataProxy] Fix the message body of msgType=5 is incorrect 
(#11435)
    
    Co-authored-by: gosonzhang <gosonzh...@tencent.com>
---
 .../java/org/apache/inlong/dataproxy/source/v0msg/CodecTextMsg.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/v0msg/CodecTextMsg.java
 
b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/v0msg/CodecTextMsg.java
index 68fb139957..ed50680aeb 100644
--- 
a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/v0msg/CodecTextMsg.java
+++ 
b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/v0msg/CodecTextMsg.java
@@ -256,7 +256,7 @@ public class CodecTextMsg extends AbsV0MsgCodec {
                 }
                 byte[] record = new byte[singleMsgLen];
                 bodyBuffer.get(record);
-                inLongMsg.addMsg(mapJoiner.join(attrMap), bodyBuffer);
+                inLongMsg.addMsg(mapJoiner.join(attrMap), record);
                 calcCnt++;
             }
             if (calcCnt != this.msgCount) {