(inlong) branch master updated: [INLONG-12195][Manager] Add tenant verification to the source/get interface (#12196)

[wakefu]

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

fuweng11 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 d78db55176 [INLONG-12195][Manager] Add tenant verification to the 
source/get interface (#12196)
d78db55176 is described below

commit d78db5517630bc6a93aa28964645520965c5554f
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Thu Aug 27 15:25:25 2026 +0800

    [INLONG-12195][Manager] Add tenant verification to the source/get interface 
(#12196)
    
    Co-authored-by: wakefu <wak...@tencent.com>
---
 .../inlong/manager/service/source/StreamSourceServiceImpl.java       | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceServiceImpl.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceServiceImpl.java
index e8c6073729..c2746e0d0a 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceServiceImpl.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceServiceImpl.java
@@ -165,6 +165,11 @@ public class StreamSourceServiceImpl implements 
StreamSourceService {
             throw new BusinessException(ErrorCodeEnum.SOURCE_INFO_NOT_FOUND,
                     String.format("source not found by id=%s", id));
         }
+        InlongGroupEntity groupEntity =
+                groupMapper.selectByGroupId(entity.getInlongGroupId());
+        if (groupEntity == null) {
+            throw new BusinessException(ErrorCodeEnum.GROUP_NOT_FOUND);
+        }
         StreamSourceOperator sourceOperator = 
operatorFactory.getInstance(entity.getSourceType());
         StreamSource streamSource = sourceOperator.getFromEntity(entity);
         LOGGER.debug("success to get source by id={}", id);