diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/CatalogManager.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/CatalogManager.scala index db94659b1033b..1a32e75114a56 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/CatalogManager.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/CatalogManager.scala @@ -158,7 +158,8 @@ class CatalogManager( } private[sql] object CatalogManager { - val SESSION_CATALOG_NAME: String = "spark_catalog" + val SESSION_CATALOG_NAME: String = + System.getProperty("spark.session.catalog.name", "spark_catalog") val SYSTEM_CATALOG_NAME = "system" val SESSION_NAMESPACE = "session" }