[spark] bugfix: set underlyingSessionCatalogEnabled correctly (#2984)

apache · Mar 11, 2024 · 2f96312 · 2f96312
1 parent d8d737f
commit 2f96312
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkGenericCatalog.java b/...-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());