[inlong] branch master updated: [INLONG-8507][Dataproxy] Modify nodeIp in dataproxy message to clientIp (#8508)

[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 17f8806842 [INLONG-8507][Dataproxy] Modify nodeIp in dataproxy message 
to clientIp (#8508)
17f8806842 is described below

commit 17f8806842ff3773193d0e468144820e08ad3286
Author: Goson Zhang <4675...@qq.com>
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)