diff --git a/python/pyspark/sql/session.py b/python/pyspark/sql/session.py index 61fa107497c6085243de46837b01d97892fe100f..8418abf99c8d57ec753fc56e28a4285346e9dae2 100644 --- a/python/pyspark/sql/session.py +++ b/python/pyspark/sql/session.py @@ -595,6 +595,7 @@ class SparkSession(object): """Stop the underlying :class:`SparkContext`. """ self._sc.stop() + SparkSession._instantiatedContext = None @since(2.0) def __enter__(self):