From b841be110c641a737bafc6db5fc269ffb2f2342e Mon Sep 17 00:00:00 2001 From: Goson Zhang <4675739@qq.com> Date: Tue, 29 Oct 2024 22:49:00 +0800 Subject: [PATCH] [INLONG-11434][DataProxy] Fix the message body of msgType=5 is incorrect (#11435) Co-authored-by: gosonzhang --- .../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 Event encEventPackage(BaseSource source, Channel channel) { } 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) {