[INLONG-11335][Manager] Move maxPacketLength to the DataProxyNodeResp…

…onse (#11336)
apache · Oct 11, 2024 · 766419c · 766419c
1 parent a4e2e2e
commit 766419c
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 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
@@ -50,9 +50,4 @@ public class DataProxyNodeInfo {
      */
     private Integer nodeLoad;
 
-    /**
-     * Node max packet length
-     */
-    private Integer maxPacketLength;
-
 }
diff --git a/...g-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/DataProxyNodeResponse.java b/...g-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/...ice/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterServiceImpl.java b/...ice/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterServiceImpl.java
@@ -960,6 +960,7 @@ public DataProxyNodeResponse getDataProxyNodes(String groupId, String protocolTy
         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 DataProxyNodeResponse getDataProxyNodes(String groupId, String protocolTy
             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 DataProxyNodeResponse getDataProxyNodesByCluster(String clusterName, Stri
         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 DataProxyNodeResponse getDataProxyNodesByCluster(String clusterName, Stri
             nodeInfo.setPort(nodeEntity.getPort());
             nodeInfo.setProtocolType(nodeEntity.getProtocolType());
             nodeInfo.setNodeLoad(nodeEntity.getNodeLoad());
-            nodeInfo.setMaxPacketLength(maxPacketLength);
             nodeList.add(nodeInfo);
         }
         response.setNodeList(nodeList);