diff --git a/python/pyspark/context.py b/python/pyspark/context.py index c1c84d001fa96..e21be0e10a3f7 100644 --- a/python/pyspark/context.py +++ b/python/pyspark/context.py @@ -191,8 +191,8 @@ def _ensure_initialized(cls, instance=None, gateway=None): SparkContext._writeToFile = SparkContext._jvm.PythonRDD.writeToFile if instance: - if SparkContext._active_spark_context and - SparkContext._active_spark_context != instance: + if (SparkContext._active_spark_context and + SparkContext._active_spark_context != instance): currentMaster = SparkContext._active_spark_context.master currentAppName = SparkContext._active_spark_context.appName callsite = SparkContext._active_spark_context._callsite