[inlong] branch master updated: [INLONG-6121][Manager] Fix source list unassigned error when list stream (#6122)

[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 bde66dcbd [INLONG-6121][Manager] Fix source list unassigned error when 
list stream (#6122)
bde66dcbd is described below

commit bde66dcbdf9073e669ff3e0912dff82b51cb1053
Author: woofyzhao <490467...@qq.com>
AuthorDate: Mon Oct 10 17:13:21 2022 +0800

    [INLONG-6121][Manager] Fix source list unassigned error when list stream 
(#6122)
---
 .../apache/inlong/manager/service/stream/InlongStreamServiceImpl.java | 4 ++++
 1 file changed, 4 insertions(+)

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 1ea31b562..87775fb29 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
@@ -146,6 +146,8 @@ public class InlongStreamServiceImpl implements 
InlongStreamService {
         streamInfo.setExtList(exts);
         List<StreamSink> sinkList = sinkService.listSink(groupId, streamId);
         streamInfo.setSinkList(sinkList);
+        List<StreamSource> sourceList = sourceService.listSource(groupId, 
streamId);
+        streamInfo.setSourceList(sourceList);
         LOGGER.info("success to get inlong stream for groupId={}", groupId);
         return streamInfo;
     }
@@ -175,6 +177,8 @@ public class InlongStreamServiceImpl implements 
InlongStreamService {
             streamInfo.setExtList(extInfos);
             List<StreamSink> sinkList = sinkService.listSink(groupId, 
streamId);
             streamInfo.setSinkList(sinkList);
+            List<StreamSource> sourceList = sourceService.listSource(groupId, 
streamId);
+            streamInfo.setSourceList(sourceList);
         });
         return streamList;
     }