(incubator-paimon) branch master updated: [spark] bugfix: set underlyingSessionCatalogEnabled correctly (#2984)

[biyan]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 2f96312c5 [spark] bugfix: set underlyingSessionCatalogEnabled 
correctly (#2984)
2f96312c5 is described below

commit 2f96312c536487d88ef72c6afdcf9f4d6c8053d1
Author: Yann Byron <biyan900...@gmail.com>
AuthorDate: Mon Mar 11 11:32:33 2024 +0800

    [spark] bugfix: set underlyingSessionCatalogEnabled correctly (#2984)
---
 .../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());