From cb3417b948f76fe87e1d88a40adf8458e2d6044c Mon Sep 17 00:00:00 2001
From: Yann <biyan900116@gmail.com>
Date: Mon, 11 Mar 2024 10:50:04 +0800
Subject: [PATCH] [spark] bugfix: set underlyingSessionCatalogEnabled correctly

---
 .../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 1e280596f833..931b1f1923d1 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 final void initialize(String name, CaseInsensitiveStringMap options) {
 
         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());