Skip to content

Commit 4fe9e1f

Browse files
authored
[spark] Fix SparkCatalog converts catalog option keys to lower case (#6708)
1 parent 2f59458 commit 4fe9e1f

File tree

1 file changed

+2
-1
lines changed
  • paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark

1 file changed

+2
-1
lines changed

paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,8 @@ public void initialize(String name, CaseInsensitiveStringMap options) {
128128
this.catalogName = name;
129129
CatalogContext catalogContext =
130130
CatalogContext.create(
131-
Options.fromMap(options), sparkSession.sessionState().newHadoopConf());
131+
Options.fromMap(options.asCaseSensitiveMap()),
132+
sparkSession.sessionState().newHadoopConf());
132133
this.catalog = CatalogFactory.createCatalog(catalogContext);
133134
this.defaultDatabase =
134135
options.getOrDefault(DEFAULT_DATABASE.key(), DEFAULT_DATABASE.defaultValue());

0 commit comments

Comments
 (0)