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());