This is an automated email from the ASF dual-hosted git repository. vernedeng pushed a commit to branch branch-1.8 in repository https://gitbox.apache.org/repos/asf/inlong.git
commit 4c94d5a1eeb50a10ff57dfd0e75ae986af350f70 Author: Goson Zhang <[email protected]> AuthorDate: Thu Jul 13 09:53:10 2023 +0800 [INLONG-8507][Dataproxy] Modify nodeIp in dataproxy message to clientIp (#8508) --- .../org/apache/inlong/dataproxy/source/httpMsg/HttpMessageHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/httpMsg/HttpMessageHandler.java b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/httpMsg/HttpMessageHandler.java index 94245e2628..9d6b4710ca 100644 --- a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/httpMsg/HttpMessageHandler.java +++ b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/httpMsg/HttpMessageHandler.java @@ -326,7 +326,7 @@ public class HttpMessageHandler extends SimpleChannelInboundHandler<FullHttpRequ strBuff.append("groupId=").append(groupId) .append("&streamId=").append(streamId) .append("&dt=").append(dataTime) - .append("&NodeIP=").append(clientIp) + .append("&clientIp=").append(clientIp) .append("&cnt=").append(strMsgCount) .append("&rt=").append(msgRcvTime) .append(AttributeConstants.SEPARATOR).append(AttributeConstants.MSG_RPT_TIME)
