diff options
| author | Jey Kottalam <jey@cs.berkeley.edu> | 2013-06-21 12:13:48 -0400 |
|---|---|---|
| committer | Jey Kottalam <jey@cs.berkeley.edu> | 2013-06-21 12:14:16 -0400 |
| commit | c75bed0eebb1f937db02eb98deecd380724f747d (patch) | |
| tree | 1ebddbc7707bb2c56869934f9e6adb34ff1da70b /python/pyspark/worker.py | |
| parent | 1ba3c173034c37ef99fc312c84943d2ab8885670 (diff) | |
| download | spark-c75bed0eebb1f937db02eb98deecd380724f747d.tar.gz spark-c75bed0eebb1f937db02eb98deecd380724f747d.tar.bz2 spark-c75bed0eebb1f937db02eb98deecd380724f747d.zip | |
Fix reporting of PySpark exceptions
Diffstat (limited to 'python/pyspark/worker.py')
| -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 f76ee3c236..379bbfd4c2 100644 --- a/python/pyspark/worker.py +++ b/python/pyspark/worker.py @@ -55,7 +55,7 @@ def main(infile, outfile): except Exception as e: write_int(-2, outfile) write_with_length(traceback.format_exc(), outfile) - raise + sys.exit(-1) finish_time = time.time() report_times(outfile, boot_time, init_time, finish_time) # Mark the beginning of the accumulators section of the output |