[INLONG-11375][Manager] Add a restriction that an IP can only belong …

…to one cluster (#11376)
apache · Oct 21, 2024 · 54e0cd3 · 54e0cd3
1 parent 8c7d31d
commit 54e0cd3
Showing 1 changed file with 13 additions and 0 deletions.
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
@@ -714,6 +714,19 @@ public Integer saveNode(ClusterNodeRequest request, String operator) {
             LOGGER.error(errMsg);
             throw new BusinessException(errMsg);
         }
+
+        // check ip if belongs to two different clusters at the same time
+        List<InlongClusterNodeEntity> existList =
+                clusterNodeMapper.selectByIpAndType(request.getIp(), request.getType());
+        if (CollectionUtils.isNotEmpty(existList)) {
+            InlongClusterEntity currentCluster = clusterMapper.selectById(existList.get(0).getParentId());
+            InlongClusterEntity targetCluster = clusterMapper.selectById(request.getParentId());
+            if (!Objects.equals(currentCluster.getId(), targetCluster.getId())) {
+                throw new BusinessException(
+                        String.format("current ip can not belong to cluster %s and %s at the same time",
+                                currentCluster.getName(), targetCluster.getName()));
+            }
+        }
         InlongClusterNodeOperator instance = clusterNodeOperatorFactory.getInstance(request.getType());
         Integer id = instance.saveOpt(request, operator);
         if (request.getIsInstall()) {