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);