Add Python Create jsparkSession to JVM's defaultSession

apache · Jan 26, 2018 · d9189ad · d9189ad
1 parent 4e7b490
commit d9189ad
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/python/pyspark/sql/session.py b/python/pyspark/sql/session.py
@@ -225,6 +225,7 @@ def __init__(self, sparkContext, jsparkSession=None):
         if SparkSession._instantiatedSession is None \
                 or SparkSession._instantiatedSession._sc._jsc is None:
             SparkSession._instantiatedSession = self
+            self._jvm.org.apache.spark.sql.SparkSession.setDefaultSession(self._jsparkSession)
 
     def _repr_html_(self):
         return """