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

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 351c8916c5 [hotfix] Rename configuration to catalogOptions
351c8916c5 is described below

commit 351c8916c526958cbcaf2c458762000b5e4ea6cc
Author: JingsongLi <[email protected]>
AuthorDate: Thu May 22 20:26:58 2025 +0800

    [hotfix] Rename configuration to catalogOptions
---
 .../main/java/org/apache/paimon/hive/clone/HiveCloneExtractor.java  | 2 +-
 .../java/org/apache/paimon/hive/clone/HiveTableCloneExtractor.java  | 2 +-
 paimon-hudi/src/main/java/org/apache/paimon/hudi/HudiFileIndex.java | 6 +++---
 .../main/java/org/apache/paimon/hudi/HudiHiveCloneExtractor.java    | 4 ++--
 4 files changed, 7 insertions(+), 7 deletions(-)

diff --git 
a/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/clone/HiveCloneExtractor.java
 
b/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/clone/HiveCloneExtractor.java
index 111924f720..51ec34bced 100644
--- 
a/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/clone/HiveCloneExtractor.java
+++ 
b/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/clone/HiveCloneExtractor.java
@@ -43,7 +43,7 @@ public interface HiveCloneExtractor {
             throws Exception;
 
     List<HivePartitionFiles> extractFiles(
-            Map<String, String> configuration,
+            Map<String, String> catalogOptions,
             IMetaStoreClient client,
             Table table,
             FileIO fileIO,
diff --git 
a/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/clone/HiveTableCloneExtractor.java
 
b/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/clone/HiveTableCloneExtractor.java
index 7ad4c37934..d363be73ad 100644
--- 
a/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/clone/HiveTableCloneExtractor.java
+++ 
b/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/clone/HiveTableCloneExtractor.java
@@ -73,7 +73,7 @@ public class HiveTableCloneExtractor implements 
HiveCloneExtractor {
 
     @Override
     public List<HivePartitionFiles> extractFiles(
-            Map<String, String> configuration,
+            Map<String, String> catalogOptions,
             IMetaStoreClient client,
             Table table,
             FileIO fileIO,
diff --git 
a/paimon-hudi/src/main/java/org/apache/paimon/hudi/HudiFileIndex.java 
b/paimon-hudi/src/main/java/org/apache/paimon/hudi/HudiFileIndex.java
index 6a6fd83ad3..792228aa2a 100644
--- a/paimon-hudi/src/main/java/org/apache/paimon/hudi/HudiFileIndex.java
+++ b/paimon-hudi/src/main/java/org/apache/paimon/hudi/HudiFileIndex.java
@@ -82,15 +82,15 @@ public class HudiFileIndex {
     public HudiFileIndex(
             String location,
             Map<String, String> tableOptions,
-            Map<String, String> configuration,
+            Map<String, String> catalogOptions,
             RowType partitionType,
             @Nullable PartitionPredicate partitionPredicate) {
         this.path = new Path(location);
         this.metadataConfig = metadataConfig(tableOptions);
         Configuration hadoopConf =
                 HadoopConfigurations.getHadoopConf(
-                        
org.apache.flink.configuration.Configuration.fromMap(configuration));
-        configuration.forEach(hadoopConf::set);
+                        
org.apache.flink.configuration.Configuration.fromMap(catalogOptions));
+        catalogOptions.forEach(hadoopConf::set);
         this.partitionType = partitionType;
         this.partitionPredicate = partitionPredicate;
         this.engineContext = new HoodieFlinkEngineContext(hadoopConf);
diff --git 
a/paimon-hudi/src/main/java/org/apache/paimon/hudi/HudiHiveCloneExtractor.java 
b/paimon-hudi/src/main/java/org/apache/paimon/hudi/HudiHiveCloneExtractor.java
index c00e57cd7e..1d54bab0dc 100644
--- 
a/paimon-hudi/src/main/java/org/apache/paimon/hudi/HudiHiveCloneExtractor.java
+++ 
b/paimon-hudi/src/main/java/org/apache/paimon/hudi/HudiHiveCloneExtractor.java
@@ -80,7 +80,7 @@ public class HudiHiveCloneExtractor extends 
HiveTableCloneExtractor {
 
     @Override
     public List<HivePartitionFiles> extractFiles(
-            Map<String, String> configuration,
+            Map<String, String> catalogOptions,
             IMetaStoreClient client,
             Table table,
             FileIO fileIO,
@@ -93,7 +93,7 @@ public class HudiHiveCloneExtractor extends 
HiveTableCloneExtractor {
 
         String location = table.getSd().getLocation();
         HudiFileIndex fileIndex =
-                new HudiFileIndex(location, options, configuration, 
partitionRowType, predicate);
+                new HudiFileIndex(location, options, catalogOptions, 
partitionRowType, predicate);
 
         if (fileIndex.isPartitioned()) {
             return fileIndex.getAllFilteredPartitionFiles(fileIO);

Reply via email to