This is an automated email from the ASF dual-hosted git repository.
wakefu pushed a commit to branch branch-1.13
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/branch-1.13 by this push:
new 29948c0a6d [INLONG-10709][Manager] fix group exist check error caused
by schedule configuration (#10710)
29948c0a6d is described below
commit 29948c0a6d3ab17ca97d4f7494f5b1888286e433
Author: AloysZhang <[email protected]>
AuthorDate: Tue Jul 23 20:57:30 2024 +0800
[INLONG-10709][Manager] fix group exist check error caused by schedule
configuration (#10710)
---
.../apache/inlong/manager/service/group/InlongGroupServiceImpl.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupServiceImpl.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupServiceImpl.java
index 40fd5e943d..6431cd9e48 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupServiceImpl.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupServiceImpl.java
@@ -255,10 +255,7 @@ public class InlongGroupServiceImpl implements
InlongGroupService {
Preconditions.expectNotNull(groupId,
ErrorCodeEnum.GROUP_ID_IS_EMPTY.getMessage());
InlongGroupEntity entity = groupMapper.selectByGroupId(groupId);
LOGGER.debug("success to check inlong group {}, exist? {}", groupId,
entity != null);
- if (entity == null) {
- return false;
- }
- return isScheduleInfoExist(entity);
+ return entity != null;
}
private boolean isScheduleInfoExist(InlongGroupEntity entity) {