This is an automated email from the ASF dual-hosted git repository. biyan pushed a commit to branch master_catalog in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
commit cb3417b948f76fe87e1d88a40adf8458e2d6044c Author: Yann <[email protected]> AuthorDate: Mon Mar 11 10:50:04 2024 +0800 [spark] bugfix: set underlyingSessionCatalogEnabled correctly --- .../src/main/java/org/apache/paimon/spark/SparkGenericCatalog.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkGenericCatalog.java b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkGenericCatalog.java index 1e280596f..931b1f192 100644 --- a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkGenericCatalog.java +++ b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkGenericCatalog.java @@ -253,7 +253,7 @@ public class SparkGenericCatalog extends SparkBaseCatalog implements CatalogExte if (options.getBoolean( SparkConnectorOptions.CREATE_UNDERLYING_SESSION_CATALOG.key(), false)) { - this.underlyingSessionCatalogEnabled = false; + this.underlyingSessionCatalogEnabled = true; for (Map.Entry<String, String> entry : options.entrySet()) { sparkConf.set("spark.hadoop." + entry.getKey(), entry.getValue()); hadoopConf.set(entry.getKey(), entry.getValue());
