You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by yi...@apache.org on 2025/11/06 00:21:55 UTC
(hudi) branch master updated: fix: Fix build because of record index config renaming (#14215)
This is an automated email from the ASF dual-hosted git repository.
yihua 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 d4700b0d5b7e fix: Fix build because of record index config renaming (#14215)
d4700b0d5b7e is described below
commit d4700b0d5b7e41d8d16887a538ec420c7aabbf61
Author: Y Ethan Guo <et...@gmail.com>
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()));
}
}