diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java index 522bdc10226..edb36d884ff 100644 --- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java +++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java @@ -340,10 +340,9 @@ public AgentConfigInfo getAgentConfig(AgentConfigRequest request) { .clusterTagList(clusterTagList) .build(); List agentZkCluster = clusterMapper.selectByCondition(pageRequest); - if (CollectionUtils.isEmpty(agentZkCluster)) { - throw new BusinessException("zk cluster for ha not found for cluster tag=" + request.getClusterTag()); + if (CollectionUtils.isNotEmpty(agentZkCluster)) { + agentConfigInfo.setZkUrl(agentZkCluster.get(0).getUrl()); } - agentConfigInfo.setZkUrl(agentZkCluster.get(0).getUrl()); AgentClusterInfo clusterInfo = (AgentClusterInfo) clusterService.getOne( null, request.getClusterName(), ClusterType.AGENT);