Skip to content

Commit af481d6

Browse files
committed
Fix python
1 parent 526896f commit af481d6

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

python/pyspark/sql/session.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -175,7 +175,7 @@ def __init__(self, sparkContext, jsparkSession=None):
175175
if jsparkSession is None:
176176
jsparkSession = self._jvm.SparkSession(self._jsc.sc())
177177
self._jsparkSession = jsparkSession
178-
self._jwrapped = self._jsparkSession.wrapped()
178+
self._jwrapped = self._jsparkSession.sqlContext()
179179
self._wrapped = SQLContext(self._sc, self, self._jwrapped)
180180
_monkey_patch_RDD(self)
181181
install_exception_handler()

0 commit comments

Comments
 (0)