fixup

apache · Dec 9, 2024 · f6df8f4 · f6df8f4
1 parent 93b72a0
commit f6df8f4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/python/pyspark/sql/session.py b/python/pyspark/sql/session.py
@@ -496,9 +496,9 @@ def getOrCreate(self) -> "SparkSession":
                             and SparkSession._instantiatedSession is None
                         ):
                             if is_api_mode_connect:
-                                url = opts.get("spark.remote", os.environ.get("SPARK_REMOTE"))
-                            else:
                                 url = opts.get("spark.master", os.environ.get("MASTER"))
+                            else:
+                                url = opts.get("spark.remote", os.environ.get("SPARK_REMOTE"))
 
                             if url is None:
                                 raise PySparkRuntimeError(