You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2023/01/10 11:47:14 UTC

[inlong] branch branch-1.5 updated: [INLONG-7206][Manager] Fix the problem of the selectBriefList method in the InlongGroupEntity.xml file is incorrect (#7207)

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

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


The following commit(s) were added to refs/heads/branch-1.5 by this push:
     new 9bd8781f3 [INLONG-7206][Manager] Fix the problem of the selectBriefList method in the InlongGroupEntity.xml file is incorrect (#7207)
9bd8781f3 is described below

commit 9bd8781f32a151900feb2345580b858d6a1c0229
Author: fuweng11 <76...@users.noreply.github.com>
AuthorDate: Tue Jan 10 19:46:29 2023 +0800

    [INLONG-7206][Manager] Fix the problem of the selectBriefList method in the InlongGroupEntity.xml file is incorrect (#7207)
---
 .../src/main/resources/mappers/InlongGroupEntityMapper.xml       | 2 +-
 .../manager/service/core/impl/InlongStreamServiceTest.java       | 9 +++++++++
 2 files changed, 10 insertions(+), 1 deletion(-)

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 77cbd6246..5ba25a183 100644
--- a/inlong-manager/manager-dao/src/main/resources/mappers/InlongGroupEntityMapper.xml
+++ b/inlong-manager/manager-dao/src/main/resources/mappers/InlongGroupEntityMapper.xml
@@ -166,7 +166,7 @@
     </select>
     <select id="selectBriefList" parameterType="org.apache.inlong.manager.pojo.group.InlongGroupPageRequest"
             resultType="org.apache.inlong.manager.pojo.group.InlongGroupBriefInfo">
-        select id, inlong_group_id, name, mq_type, mq_resource, dataReportType, inlong_cluster_tag, ext_params,
+        select id, inlong_group_id, name, mq_type, mq_resource, inlong_cluster_tag, ext_params,
                in_charges, status, creator, modifier, create_time, modify_time
         from inlong_group
         <where>
diff --git a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/impl/InlongStreamServiceTest.java b/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/impl/InlongStreamServiceTest.java
index 74772fe84..a026e0161 100644
--- a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/impl/InlongStreamServiceTest.java
+++ b/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/impl/InlongStreamServiceTest.java
@@ -17,6 +17,9 @@
 
 package org.apache.inlong.manager.service.core.impl;
 
+import org.apache.inlong.manager.dao.mapper.InlongGroupEntityMapper;
+import org.apache.inlong.manager.pojo.group.InlongGroupBriefInfo;
+import org.apache.inlong.manager.pojo.group.InlongGroupPageRequest;
 import org.apache.inlong.manager.pojo.stream.InlongStreamInfo;
 import org.apache.inlong.manager.pojo.stream.InlongStreamRequest;
 import org.apache.inlong.manager.service.group.InlongGroupServiceTest;
@@ -27,6 +30,8 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.TestComponent;
 
+import java.util.List;
+
 /**
  * Inlong stream service test
  */
@@ -39,6 +44,8 @@ public class InlongStreamServiceTest {
     private InlongStreamService streamService;
     @Autowired
     private InlongGroupServiceTest groupServiceTest;
+    @Autowired
+    private InlongGroupEntityMapper groupMapper;
 
     /**
      * Test save inlong stream
@@ -54,6 +61,8 @@ public class InlongStreamServiceTest {
         }
 
         groupServiceTest.saveGroup(groupId, operator);
+        InlongGroupPageRequest groupRequest = InlongGroupPageRequest.builder().build();
+        List<InlongGroupBriefInfo> groupList = groupMapper.selectBriefList(groupRequest);
 
         InlongStreamRequest request = new InlongStreamRequest();
         request.setInlongGroupId(groupId);