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 entry : options.entrySet()) { sparkConf.set("spark.hadoop." + entry.getKey(), entry.getValue()); hadoopConf.set(entry.getKey(), entry.getValue());