(inlong) branch master updated: [INLONG-11071][Manager] Fix: failed to handle request on inlong_agent_system by admin (#11099)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 807717a4b9 [INLONG-11071][Manager] Fix: failed to handle request on 
inlong_agent_system by admin (#11099)
807717a4b9 is described below

commit 807717a4b9f182a16dd6df7dff0a754baaea7fca
Author: Haotian Ma <60374114+qy-liu...@users.noreply.github.com>
AuthorDate: Sat Sep 14 12:57:33 2024 +0800

    [INLONG-11071][Manager] Fix: failed to handle request on 
inlong_agent_system by admin (#11099)
---
 .../inlong/manager/service/cluster/InlongClusterServiceImpl.java     | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterServiceImpl.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterServiceImpl.java
index 7caef673dd..f399455803 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterServiceImpl.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterServiceImpl.java
@@ -910,6 +910,11 @@ public class InlongClusterServiceImpl implements 
InlongClusterService {
         LOGGER.debug("begin to get data proxy nodes for groupId={}, 
protocol={}", groupId, protocolType);
 
         InlongGroupEntity groupEntity = groupMapper.selectByGroupId(groupId);
+        if (groupEntity == null) {
+            String errMsg = String.format("group not found by groupId=%s", 
groupId);
+            LOGGER.error(errMsg);
+            throw new BusinessException(errMsg);
+        }
         GroupStatus groupStatus = GroupStatus.forCode(groupEntity.getStatus());
         if (!Objects.equals(groupStatus, GroupStatus.CONFIG_SUCCESSFUL)) {
             String errMsg =