diff options
| author | jyotiska <jyotiska123@gmail.com> | 2014-02-22 10:09:50 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-02-22 10:09:50 -0800 |
| commit | 3ff077d489af99ad36c9d2389e2afab6465648d4 (patch) | |
| tree | 93a9ade5e78f1bfdb9b01c012d6c39ecffebd7d3 /python | |
| parent | aaec7d4a80ed370847671e9e29ce2e92f1cff2c7 (diff) | |
| download | spark-3ff077d489af99ad36c9d2389e2afab6465648d4.tar.gz spark-3ff077d489af99ad36c9d2389e2afab6465648d4.tar.bz2 spark-3ff077d489af99ad36c9d2389e2afab6465648d4.zip | |
Fixed minor typo in worker.py
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
Diffstat (limited to 'python')
| -rw-r--r-- | python/pyspark/worker.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/worker.py b/python/pyspark/worker.py index 4be4063dcf..1586463520 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() |