[INLONG-10834][Manager] Fix comment

fuweng11 · Aug 21, 2024 · 87232cf · 87232cf
1 parent 5a80a36
commit 87232cf
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...ice/src/main/java/org/apache/inlong/manager/service/cluster/ClusterConfigServiceImpl.java b/...ice/src/main/java/org/apache/inlong/manager/service/cluster/ClusterConfigServiceImpl.java
@@ -69,6 +69,9 @@ public boolean refresh(String clusterTag, String operator) {
                     .typeList(Arrays.asList(ClusterType.TUBEMQ, ClusterType.PULSAR, ClusterType.KAFKA))
                     .build();
             List<InlongClusterEntity> clusterEntityList = clusterEntityMapper.selectByCondition(request);
+            if (CollectionUtils.isEmpty(clusterEntityList)) {
+                throw new BusinessException("Current cluster tag not contain MQ clusters");
+            }
             List<String> typeList = clusterEntityList.stream().map(InlongClusterEntity::getType).distinct().collect(
                     Collectors.toList());
             if (CollectionUtils.isNotEmpty(typeList) && typeList.size() > 1) {