From 94aa0280baf6d0cec55909d1e731076680bdbd88 Mon Sep 17 00:00:00 2001 From: fuwenkai <834260992@qq.com> Date: Mon, 17 Jun 2024 18:43:48 +0800 Subject: [PATCH] [INLONG-10438][Manager] GetConfig does not throw an exception when obtaining the zk address fails --- .../inlong/manager/service/core/impl/AgentServiceImpl.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) 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);