Update inlong-manager/manager-service/src/main/java/org/apache/inlong…

…/manager/service/sink/StreamSinkServiceImpl.java Co-authored-by: AloysZhang <[email protected]>
apache · Apr 17, 2024 · f5b73f6 · f5b73f6
1 parent 97adce8
commit f5b73f6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...r-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkServiceImpl.java b/...r-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkServiceImpl.java
@@ -241,8 +241,8 @@ public List<BatchResult> batchSave(List<SinkRequest> requestList, String operato
         List<BatchResult> resultList = new ArrayList<>();
         for (SinkRequest request : requestList) {
             BatchResult result = BatchResult.builder()
-                    .uniqueKey(request.getSinkName() + "-" + request.getInlongGroupId() + "-"
-                            + request.getInlongStreamId())
+                    .uniqueKey(request.getInlongGroupId() + "-"
+                            + request.getInlongStreamId() + "-" + request.getSinkName() )
                     .operationTarget(OperationTarget.SINK)
                     .build();
             try {