update

AngersZhuuuu · AngersZhuuuu · commit b33d254c8b7c · 2021-11-29T15:07:52.000+08:00
diff --git a/python/pyspark/sql/tests/test_session.py b/python/pyspark/sql/tests/test_session.py
@@ -61,7 +61,7 @@ def test_set_jvm_default_session(self):
 
     def test_jvm_default_session_already_set(self):
         # Here, we assume there is the default session already set in JVM.
-        jsession = self.sc._jvm.SparkSession(self.sc._jsc.sc(), self.sc._jvm.PythonUtils.toScalaMap({}))
+        jsession = self.sc._jvm.SparkSession(self.sc._jsc.sc())
         self.sc._jvm.SparkSession.setDefaultSession(jsession)
 
         spark = SparkSession.builder.getOrCreate()
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
@@ -91,8 +91,6 @@ class SparkSession private(
   // The call site where this SparkSession was constructed.
   private val creationSite: CallSite = Utils.getCallSite()
 
-  private[sql] def this(sc: SparkContext) = this(sc, Map.empty)
-
   /**
    * Constructor used in Pyspark. Contains explicit application of Spark Session Extensions
    * which otherwise only occurs during getOrCreate. We cannot add this to the default constructor
@@ -106,6 +104,8 @@ class SparkSession private(
         new SparkSessionExtensions), initialSessionOptions)
   }
 
+  private[sql] def this(sc: SparkContext) = this(sc, Map.empty)
+
   private[sql] val sessionUUID: String = UUID.randomUUID.toString
 
   sparkContext.assertNotStopped()
