(inlong) branch master updated: [INLONG-11335][Manager] Move maxPacketLength to the DataProxyNodeResponse (#11336)

[aloyszhang]

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

aloyszhang 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 766419ca7f [INLONG-11335][Manager] Move maxPacketLength to the 
DataProxyNodeResponse (#11336)
766419ca7f is described below

commit 766419ca7fb5f121e46dfbf8eb2a303bb4d43ea3
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Fri Oct 11 17:22:15 2024 +0800

    [INLONG-11335][Manager] Move maxPacketLength to the DataProxyNodeResponse 
(#11336)
---
 .../org/apache/inlong/common/pojo/dataproxy/DataProxyNodeInfo.java   | 5 -----
 .../apache/inlong/common/pojo/dataproxy/DataProxyNodeResponse.java   | 5 +++++
 .../inlong/manager/service/cluster/InlongClusterServiceImpl.java     | 4 ++--
 3 files changed, 7 insertions(+), 7 deletions(-)

diff --git 
a/inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/DataProxyNodeInfo.java
 
b/inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/DataProxyNodeInfo.java
index 87d081d79a..6ecbcba4c7 100644
--- 
a/inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/DataProxyNodeInfo.java
+++ 
b/inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/DataProxyNodeInfo.java
@@ -50,9 +50,4 @@ public class DataProxyNodeInfo {
      */
     private Integer nodeLoad;
 
-    /**
-     * Node max packet length
-     */
-    private Integer maxPacketLength;
-
 }
diff --git 
a/inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/DataProxyNodeResponse.java
 
b/inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/DataProxyNodeResponse.java
index 7b53ef96db..0d7237fdfe 100644
--- 
a/inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/DataProxyNodeResponse.java
+++ 
b/inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/DataProxyNodeResponse.java
@@ -50,6 +50,11 @@ public class DataProxyNodeResponse {
      */
     private Integer load = 20;
 
+    /**
+     * Node max packet length
+     */
+    private Integer maxPacketLength;
+
     /**
      * List of the cluster node
      */
diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterServiceImpl.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterServiceImpl.java
index 99505b1bfe..c97971900e 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterServiceImpl.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterServiceImpl.java
@@ -960,6 +960,7 @@ public class InlongClusterServiceImpl implements 
InlongClusterService {
         if (dataProxyCluster != null && 
StringUtils.isNotBlank(dataProxyCluster.getExtParams())) {
             DataProxyClusterDTO dataProxyClusterDTO = 
DataProxyClusterDTO.getFromJson(dataProxyCluster.getExtParams());
             maxPacketLength = dataProxyClusterDTO.getMaxPacketLength();
+            response.setMaxPacketLength(maxPacketLength);
         }
 
         // TODO consider the data proxy load and re-balance
@@ -978,7 +979,6 @@ public class InlongClusterServiceImpl implements 
InlongClusterService {
             nodeInfo.setPort(nodeEntity.getPort());
             nodeInfo.setProtocolType(nodeEntity.getProtocolType());
             nodeInfo.setNodeLoad(nodeEntity.getNodeLoad());
-            nodeInfo.setMaxPacketLength(maxPacketLength);
             nodeList.add(nodeInfo);
         }
         response.setNodeList(nodeList);
@@ -1004,6 +1004,7 @@ public class InlongClusterServiceImpl implements 
InlongClusterService {
         if (StringUtils.isNotBlank(clusterEntity.getExtParams())) {
             DataProxyClusterDTO dataProxyClusterDTO = 
DataProxyClusterDTO.getFromJson(clusterEntity.getExtParams());
             maxPacketLength = dataProxyClusterDTO.getMaxPacketLength();
+            response.setMaxPacketLength(maxPacketLength);
         }
         List<InlongClusterNodeEntity> nodeEntities =
                 clusterNodeMapper.selectByParentId(clusterEntity.getId(), 
protocolType);
@@ -1041,7 +1042,6 @@ public class InlongClusterServiceImpl implements 
InlongClusterService {
             nodeInfo.setPort(nodeEntity.getPort());
             nodeInfo.setProtocolType(nodeEntity.getProtocolType());
             nodeInfo.setNodeLoad(nodeEntity.getNodeLoad());
-            nodeInfo.setMaxPacketLength(maxPacketLength);
             nodeList.add(nodeInfo);
         }
         response.setNodeList(nodeList);