Repository: incubator-spark Updated Branches: refs/heads/master aaec7d4a8 -> 3ff077d48
Fixed minor typo in worker.py Fixed minor typo in worker.py Author: jyotiska <jyotiska...@gmail.com> Closes #630 from jyotiska/pyspark_code and squashes the following commits: ee44201 [jyotiska] typo fixed in worker.py Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/3ff077d4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/3ff077d4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/3ff077d4 Branch: refs/heads/master Commit: 3ff077d489af99ad36c9d2389e2afab6465648d4 Parents: aaec7d4 Author: jyotiska <jyotiska...@gmail.com> Authored: Sat Feb 22 10:09:50 2014 -0800 Committer: Patrick Wendell <pwend...@gmail.com> Committed: Sat Feb 22 10:09:50 2014 -0800 ---------------------------------------------------------------------- python/pyspark/worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/3ff077d4/python/pyspark/worker.py ---------------------------------------------------------------------- diff --git a/python/pyspark/worker.py b/python/pyspark/worker.py index 4be4063..1586463 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()
