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 {