Skip to content

Commit

Permalink
typo fixed in worker.py
Browse files Browse the repository at this point in the history
  • Loading branch information
jyotiska committed Feb 22, 2014
1 parent 79c9552 commit ee44201
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion python/pyspark/worker.py
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand Down

0 comments on commit ee44201

Please sign in to comment.