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