[hudi] branch master updated: [HUDI-6655] Fix TestWriteMergeOnRead#testConsistentBucketIndex (#9380)

[danny0405]

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

danny0405 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 af3b2937a38 [HUDI-6655] Fix 
TestWriteMergeOnRead#testConsistentBucketIndex (#9380)
af3b2937a38 is described below

commit af3b2937a388f8b35fedf342b51ad2348065db1d
Author: Jing Zhang <beyond1...@gmail.com>
AuthorDate: Mon Aug 7 19:34:02 2023 +0800

    [HUDI-6655] Fix TestWriteMergeOnRead#testConsistentBucketIndex (#9380)
---
 .../table/action/cluster/util/ConsistentHashingUpdateStrategyUtils.java | 2 +-
 .../src/test/java/org/apache/hudi/sink/TestWriteMergeOnRead.java        | 2 --
 2 files changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/util/ConsistentHashingUpdateStrategyUtils.java
 
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/util/ConsistentHashingUpdateStrategyUtils.java
index f8351d2fa93..873badbd185 100644
--- 
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/util/ConsistentHashingUpdateStrategyUtils.java
+++ 
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/util/ConsistentHashingUpdateStrategyUtils.java
@@ -83,7 +83,7 @@ public class ConsistentHashingUpdateStrategyUtils {
       ValidationUtils.checkState(p != null, "Clustering plan does not has 
partition info, plan: " + plan);
       // Skip unrelated clustering group
       if (!recordPartitions.contains(p)) {
-        return;
+        continue;
       }
 
       String preInstant = partitionToInstant.putIfAbsent(p, instant);
diff --git 
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteMergeOnRead.java
 
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteMergeOnRead.java
index c899b1bb234..94214661ea8 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteMergeOnRead.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteMergeOnRead.java
@@ -26,7 +26,6 @@ import org.apache.hudi.configuration.FlinkOptions;
 import org.apache.hudi.utils.TestData;
 
 import org.apache.flink.configuration.Configuration;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ValueSource;
@@ -165,7 +164,6 @@ public class TestWriteMergeOnRead extends 
TestWriteCopyOnWrite {
   }
 
   @Test
-  @Disabled("HUDI-6655")
   public void testConsistentBucketIndex() throws Exception {
     conf.setString(FlinkOptions.INDEX_TYPE, "BUCKET");
     conf.setString(FlinkOptions.BUCKET_INDEX_ENGINE_TYPE, 
"CONSISTENT_HASHING");