[inlong] branch master updated: [INLONG-8496][Manager] Fix calling openAPI to save stream failed (#8497)

[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 3e3d26586a [INLONG-8496][Manager] Fix calling openAPI to save stream 
failed (#8497)
3e3d26586a is described below

commit 3e3d26586af7b61b9702865fee251b880786a132
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
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());