Support custom spark.sql.catalogImplementation

joomcode · Oct 11, 2024 · 13d763b · 13d763b
1 parent b38128b
commit 13d763b
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala b/sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala
@@ -1289,11 +1289,10 @@ object SparkSession extends Logging {
     "org.apache.spark.sql.hive.HiveSessionStateBuilder"
 
   private def sessionStateClassName(conf: SparkConf): String = {
-    log.warn("!THIS IS CORRECT PACKAGE!")
     conf.get(CATALOG_IMPLEMENTATION) match {
       case "hive" => HIVE_SESSION_STATE_BUILDER_CLASS_NAME
       case "in-memory" => classOf[SessionStateBuilder].getCanonicalName
-      case _ => conf.get(CATALOG_IMPLEMENTATION)
+      case _ => HIVE_SESSION_STATE_BUILDER_CLASS_NAME
     }
   }