[HUDI-5373] Different fileids are assigned to the same bucket (apache…

…#7433)
fengjian428 · Apr 5, 2023 · 4b68f3e · 4b68f3e
1 parent c7770ed
commit 4b68f3e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/BucketStreamWriteFunction.java b/...ource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/BucketStreamWriteFunction.java
@@ -111,7 +111,7 @@ public void processElement(I i, ProcessFunction<I, Object>.Context context, Coll
     bootstrapIndexIfNeed(partition);
     Map<Integer, String> bucketToFileId = bucketIndex.computeIfAbsent(partition, p -> new HashMap<>());
     final int bucketNum = BucketIdentifier.getBucketId(hoodieKey, indexKeyFields, this.bucketNum);
-    final String bucketId = partition + bucketNum;
+    final String bucketId = partition + "/" + bucketNum;
 
     if (incBucketIndex.contains(bucketId)) {
       location = new HoodieRecordLocation("I", bucketToFileId.get(bucketNum));