[hudi] branch master updated: [MINOR] Fix consistent hashing bucket index FT failure (#9401)

[leesf]

This is an automated email from the ASF dual-hosted git repository.

leesf pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 9b22583dbe0 [MINOR] Fix consistent hashing bucket index FT failure 
(#9401)
9b22583dbe0 is described below

commit 9b22583dbe089df1c0014ee88f250a3e516667ce
Author: StreamingFlames <18889897...@163.com>
AuthorDate: Wed Aug 9 17:26:57 2023 +0800

    [MINOR] Fix consistent hashing bucket index FT failure (#9401)
---
 .../org/apache/hudi/client/functional/TestConsistentBucketIndex.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestConsistentBucketIndex.java
 
b/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestConsistentBucketIndex.java
index 01b05f07642..b23259c1264 100644
--- 
a/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestConsistentBucketIndex.java
+++ 
b/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestConsistentBucketIndex.java
@@ -228,8 +228,8 @@ public class TestConsistentBucketIndex extends 
HoodieSparkClientTestHarness {
     Assertions.assertEquals(numFilesCreated,
         Arrays.stream(dataGen.getPartitionPaths()).mapToInt(p -> 
Objects.requireNonNull(listStatus(p, true)).length).sum());
 
-    // BulkInsert again.
-    writeData(writeRecords, "002", WriteOperationType.BULK_INSERT,true);
+    // Upsert Data
+    writeData(writeRecords, "002", WriteOperationType.UPSERT,true);
     // The total number of file group should be the same, but each file group 
will have a log file.
     Assertions.assertEquals(numFilesCreated,
         Arrays.stream(dataGen.getPartitionPaths()).mapToInt(p -> 
Objects.requireNonNull(listStatus(p, true)).length).sum());