diff --git a/python/pyspark/worker.py b/python/pyspark/worker.py index 4be4063dcf6..15864635203 100644 --- a/python/pyspark/worker.py +++ b/python/pyspark/worker.py @@ -76,7 +76,7 @@ def main(infile, outfile): iterator = deserializer.load_stream(infile) serializer.dump_stream(func(split_index, iterator), outfile) except Exception as e: - # Write the error to stderr in addition to trying to passi t back to + # Write the error to stderr in addition to trying to pass it back to # Java, in case it happened while serializing a record print >> sys.stderr, "PySpark worker failed with exception:" print >> sys.stderr, traceback.format_exc()