diff --git a/python/pyspark/worker.py b/python/pyspark/worker.py index 9b54affb137f5..84e5cca5d3c00 100644 --- a/python/pyspark/worker.py +++ b/python/pyspark/worker.py @@ -468,7 +468,7 @@ def main(infile, outfile): version = utf8_deserializer.loads(infile) if version != "%d.%d" % sys.version_info[:2]: raise Exception(("Python in worker has different version %s than that in " + - "driver %s, PySpark cannot run with different minor versions." + + "driver %s, PySpark cannot run with different minor versions. " + "Please check environment variables PYSPARK_PYTHON and " + "PYSPARK_DRIVER_PYTHON are correctly set.") % ("%d.%d" % sys.version_info[:2], version))