From 30116c4f4d2cf36e2e43f933059e9c9b49fda041 Mon Sep 17 00:00:00 2001 From: Charles Zhang Date: Wed, 17 Apr 2024 15:24:04 +0800 Subject: [PATCH] Update inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceServiceImpl.java Co-authored-by: AloysZhang --- .../manager/service/source/StreamSourceServiceImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 37795e8b2fa..62807b2b7c1 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 @@ -169,8 +169,8 @@ public List batchSave(List requestList, String opera List resultList = new ArrayList<>(); for (SourceRequest request : requestList) { BatchResult result = BatchResult.builder() - .uniqueKey(request.getSourceName() + "-" + request.getInlongGroupId() + "-" - + request.getInlongStreamId()) + .uniqueKey(request.getInlongGroupId() + "-" + + request.getInlongStreamId() + "-" + request.getSourceName()) .operationTarget(OperationTarget.SOURCE) .build(); try {