[inlong] 03/05: [INLONG-6440][Manager] Fix heartbeat information error for IP (#6444)

[dockerzhang]

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

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

commit 448dada0a88907d40a604c706daaa5caad2dace7
Author: ganfengtan <ganfeng...@users.noreply.github.com>
AuthorDate: Tue Nov 8 11:39:09 2022 +0800

    [INLONG-6440][Manager] Fix heartbeat information error for IP (#6444)
---
 .../org/apache/inlong/manager/service/heartbeat/HeartbeatManager.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/heartbeat/HeartbeatManager.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/heartbeat/HeartbeatManager.java
index d38a92510..010afee02 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/heartbeat/HeartbeatManager.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/heartbeat/HeartbeatManager.java
@@ -153,6 +153,7 @@ public class HeartbeatManager implements 
AbstractHeartbeatManager {
 
         // protocolType may be null, and the protocolTypes' length may be less 
than ports' length
         String[] ports = heartbeat.getPort().split(InlongConstants.COMMA);
+        String[] ips = heartbeat.getIp().split(InlongConstants.COMMA);
         String protocolType = heartbeat.getProtocolType();
         String[] protocolTypes = null;
         if (StringUtils.isNotBlank(protocolType) && ports.length > 1) {
@@ -167,6 +168,7 @@ public class HeartbeatManager implements 
AbstractHeartbeatManager {
             HeartbeatMsg heartbeatMsg = 
JsonUtils.parseObject(JsonUtils.toJsonByte(heartbeat), HeartbeatMsg.class);
             assert heartbeatMsg != null;
             heartbeatMsg.setPort(ports[i].trim());
+            heartbeatMsg.setIp(ips[i].trim());
             if (protocolTypes != null) {
                 heartbeatMsg.setProtocolType(protocolTypes[i]);
             } else {