Fix python style

apache · Jan 29, 2018 · d9f77ea · d9f77ea
1 parent ec94c05
commit d9f77ea
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/python/pyspark/sql/session.py b/python/pyspark/sql/session.py
@@ -214,7 +214,8 @@ def __init__(self, sparkContext, jsparkSession=None):
         self._jvm = self._sc._jvm
         if jsparkSession is None:
             if self._jvm.SparkSession.getDefaultSession().isDefined() \
-                and not self._jvm.SparkSession.getDefaultSession().get().sparkContext().isStopped():
+                    and not self._jvm.SparkSession.getDefaultSession().get() \
+                            .sparkContext().isStopped():
                 jsparkSession = self._jvm.SparkSession.getDefaultSession().get()
             else:
                 jsparkSession = self._jvm.SparkSession(self._jsc.sc())
@@ -230,7 +231,7 @@ def __init__(self, sparkContext, jsparkSession=None):
                 or SparkSession._instantiatedSession._sc._jsc is None:
             SparkSession._instantiatedSession = self
             if self._jvm.SparkSession.getDefaultSession().isEmpty() \
-                or not jsparkSession.equals(self._jvm.SparkSession.getDefaultSession().get()):
+                    or not jsparkSession.equals(self._jvm.SparkSession.getDefaultSession().get()):
                 self._jvm.SparkSession.setDefaultSession(self._jsparkSession)
 
     def _repr_html_(self):