diff --git a/python/pyspark/sql/session.py b/python/pyspark/sql/session.py index de2eb4970f73..2ba1361cca0b 100644 --- a/python/pyspark/sql/session.py +++ b/python/pyspark/sql/session.py @@ -458,7 +458,7 @@ def getOrCreate(self) -> "SparkSession": else: raise RuntimeError( "Cannot start a remote Spark session because there " - "is a regular Spark Connect already running." + "is a regular Spark session already running." ) session = SparkSession._instantiatedSession