ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Fixed minor typo in worker.py

Browse source 
Fixed minor typo in worker.py

Author: jyotiska <jyotiska123@gmail.com>

Closes #630 from jyotiska/pyspark_code and squashes the following commits:

ee44201 [jyotiska] typo fixed in worker.py
This commit is contained in:
jyotiska 2014-02-22 10:09:50 -08:00 committed by Patrick Wendell
parent aaec7d4a80
commit 3ff077d489
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
python/pyspark/worker.py
View file

@ -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()