From 87cbea16a3232f6558e37bdd753875c709667cc9 Mon Sep 17 00:00:00 2001
From: wakefu <wakefu@tencent.com>
Date: Thu, 27 Aug 2026 11:06:29 +0800
Subject: [PATCH] [INLONG-12195][Manager] Add tenant verification to the
 source/get interface

---
 .../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 StreamSource get(Integer id) {
             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);