This is an automated email from the ASF dual-hosted git repository. yihua pushed a commit to branch release-1.1.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit c52d711e3ee89e2932d4c9c3921fd529f799537d Author: Y Ethan Guo <[email protected]> AuthorDate: Wed Nov 5 16:21:49 2025 -0800 fix: Fix build because of record index config renaming (#14215) --- .../org/apache/hudi/table/upgrade/UpgradeDowngradeUtils.java | 10 +++++----- .../apache/hudi/table/upgrade/TestUpgradeDowngradeUtils.java | 6 +++--- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/UpgradeDowngradeUtils.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/UpgradeDowngradeUtils.java index 9d08375cfebe..7ea0d4ccb162 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/UpgradeDowngradeUtils.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/UpgradeDowngradeUtils.java @@ -56,9 +56,9 @@ import org.apache.hudi.config.HoodieLockConfig; import org.apache.hudi.config.HoodieWriteConfig; import org.apache.hudi.exception.HoodieException; import org.apache.hudi.exception.HoodieIOException; +import org.apache.hudi.metadata.HoodieIndexVersion; import org.apache.hudi.metadata.HoodieTableMetadata; import org.apache.hudi.metadata.HoodieTableMetadataUtil; -import org.apache.hudi.metadata.HoodieIndexVersion; import org.apache.hudi.metadata.MetadataPartitionType; import org.apache.hudi.storage.StoragePath; import org.apache.hudi.table.HoodieTable; @@ -76,9 +76,9 @@ import java.time.format.DateTimeFormatter; import java.util.Arrays; import java.util.Collections; import java.util.HashSet; +import java.util.List; import java.util.Map; import java.util.Set; -import java.util.List; import java.util.stream.Collectors; import static org.apache.hudi.common.table.timeline.HoodieTimeline.CLUSTERING_ACTION; @@ -265,12 +265,12 @@ public class UpgradeDowngradeUtils { if (indexDefinitions.containsKey(HoodieTableMetadataUtil.PARTITION_NAME_RECORD_INDEX)) { Map<String, String> options = indexDefinitions.get(HoodieTableMetadataUtil.PARTITION_NAME_RECORD_INDEX).getIndexOptions(); if (options.getOrDefault("isPartitioned", FALSE).equals(TRUE)) { - properties.put(HoodieMetadataConfig.PARTITIONED_RECORD_INDEX_ENABLE_PROP.key(), TRUE); + properties.put(HoodieMetadataConfig.RECORD_LEVEL_INDEX_ENABLE_PROP.key(), TRUE); } else { - properties.put(HoodieMetadataConfig.RECORD_INDEX_ENABLE_PROP.key(), TRUE); + properties.put(HoodieMetadataConfig.GLOBAL_RECORD_LEVEL_INDEX_ENABLE_PROP.key(), TRUE); } } else { - properties.put(HoodieMetadataConfig.RECORD_INDEX_ENABLE_PROP.key(), TRUE); + properties.put(HoodieMetadataConfig.GLOBAL_RECORD_LEVEL_INDEX_ENABLE_PROP.key(), TRUE); } break; default: diff --git a/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/upgrade/TestUpgradeDowngradeUtils.java b/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/upgrade/TestUpgradeDowngradeUtils.java index 1f1ec23b804e..732373953002 100644 --- a/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/upgrade/TestUpgradeDowngradeUtils.java +++ b/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/upgrade/TestUpgradeDowngradeUtils.java @@ -132,7 +132,7 @@ class TestUpgradeDowngradeUtils { assertEquals(TRUE, properties.getString(HoodieMetadataConfig.ENABLE.key())); assertEquals(TRUE, properties.getString(HoodieMetadataConfig.ENABLE_METADATA_INDEX_COLUMN_STATS.key())); assertEquals(TRUE, properties.getString(HoodieMetadataConfig.ENABLE_METADATA_INDEX_BLOOM_FILTER.key())); - assertEquals(TRUE, properties.getString(HoodieMetadataConfig.RECORD_INDEX_ENABLE_PROP.key())); + assertEquals(TRUE, properties.getString(HoodieMetadataConfig.GLOBAL_RECORD_LEVEL_INDEX_ENABLE_PROP.key())); } @Test @@ -178,7 +178,7 @@ class TestUpgradeDowngradeUtils { setPropertiesBasedOnMetadataPartitions(properties, partitions, table); assertEquals(TRUE, properties.getString(HoodieMetadataConfig.ENABLE.key())); - assertEquals(TRUE, properties.getString(HoodieMetadataConfig.PARTITIONED_RECORD_INDEX_ENABLE_PROP.key())); + assertEquals(TRUE, properties.getString(HoodieMetadataConfig.RECORD_LEVEL_INDEX_ENABLE_PROP.key())); } @ParameterizedTest @@ -204,6 +204,6 @@ class TestUpgradeDowngradeUtils { setPropertiesBasedOnMetadataPartitions(properties, partitions, table); assertEquals(TRUE, properties.getString(HoodieMetadataConfig.ENABLE.key())); - assertEquals(TRUE, properties.getString(HoodieMetadataConfig.RECORD_INDEX_ENABLE_PROP.key())); + assertEquals(TRUE, properties.getString(HoodieMetadataConfig.GLOBAL_RECORD_LEVEL_INDEX_ENABLE_PROP.key())); } }
