[HUDI-5822] Fix FileId not found exception when FileId is passed to H…

…oodieMergeHandle
apache · Mar 22, 2023 · 6aa7bc9 · 6aa7bc9
1 parent 285de8f
commit 6aa7bc9
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
@@ -162,7 +162,7 @@ private void bootstrapIndexIfNeed(String partition) {
       int bucketNumber = BucketIdentifier.bucketIdFromFileId(fileId);
       if (isBucketToLoad(bucketNumber, partition)) {
         LOG.info(String.format("Should load this partition bucket %s with fileId %s", bucketNumber, fileId));
-        // Ensure that one bucketId has only ONE fileId
+        // Validate that one bucketId has only ONE fileId
         if (bucketToFileIDMap.containsKey(bucketNumber)) {
           throw new RuntimeException(String.format("Duplicate fileId %s from bucket %s of partition %s found "
               + "during the BucketStreamWriteFunction index bootstrap.", fileId, bucketNumber, partition));