diff --git a/python/pyspark/worker.py b/python/pyspark/worker.py index 4be4063dcf602c494c4c23bfd3ed44e826b34eaf..158646352039fcbab79c7857340d76e08d8a8754 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()