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 <[email protected]>
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 =
