This is an automated email from the ASF dual-hosted git repository. vernedeng pushed a commit to branch branch-1.8 in repository https://gitbox.apache.org/repos/asf/inlong.git
commit 8fdb9df08f8744589bb4e4fcb2a65404103038eb Author: fuweng11 <[email protected]> AuthorDate: Tue Jul 11 16:30:25 2023 +0800 [INLONG-8496][Manager] Fix calling openAPI to save stream failed (#8497) --- .../src/main/resources/mappers/InlongGroupEntityMapper.xml | 2 +- .../inlong/manager/service/stream/InlongStreamServiceImpl.java | 6 +----- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/inlong-manager/manager-dao/src/main/resources/mappers/InlongGroupEntityMapper.xml b/inlong-manager/manager-dao/src/main/resources/mappers/InlongGroupEntityMapper.xml index 9fd4eef3a7..61cd905ede 100644 --- a/inlong-manager/manager-dao/src/main/resources/mappers/InlongGroupEntityMapper.xml +++ b/inlong-manager/manager-dao/src/main/resources/mappers/InlongGroupEntityMapper.xml @@ -151,7 +151,7 @@ #{description,jdbcType=VARCHAR}, </if> <if test="tenant != null and tenant != ''"> - t#{tenant,jdbcType=VARCHAR}, + #{tenant,jdbcType=VARCHAR}, </if> <if test="mqType != null and mqType != ''"> #{mqType,jdbcType=VARCHAR}, diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/stream/InlongStreamServiceImpl.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/stream/InlongStreamServiceImpl.java index fcceb0c0b2..a3172b809b 100644 --- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/stream/InlongStreamServiceImpl.java +++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/stream/InlongStreamServiceImpl.java @@ -477,11 +477,7 @@ public class InlongStreamServiceImpl implements InlongStreamService { if (entity == null) { throw new BusinessException(ErrorCodeEnum.GROUP_NOT_FOUND); } - // check record version - Preconditions.expectEquals(entity.getVersion(), request.getVersion(), - ErrorCodeEnum.CONFIG_EXPIRED, - String.format("record has expired with record version=%d, request version=%d", - entity.getVersion(), request.getVersion())); + // only the person in charges can query userService.checkUser(entity.getInCharges(), opInfo.getName(), ErrorCodeEnum.GROUP_PERMISSION_DENIED.getMessage());
