diff options
| author | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2013-02-03 06:44:11 +0000 |
|---|---|---|
| committer | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2013-02-03 06:44:11 +0000 |
| commit | 2415c18f48fc28d88f29b88c312f98054f530f20 (patch) | |
| tree | 182f6a82babf093b902407e2cdb8717bf97413cc /python/pyspark/rdd.py | |
| parent | ae26911ec0d768dcdae8b7d706ca4544e36535e6 (diff) | |
| download | spark-2415c18f48fc28d88f29b88c312f98054f530f20.tar.gz spark-2415c18f48fc28d88f29b88c312f98054f530f20.tar.bz2 spark-2415c18f48fc28d88f29b88c312f98054f530f20.zip | |
Fix reporting of PySpark doctest failures.
Diffstat (limited to 'python/pyspark/rdd.py')
| -rw-r--r-- | python/pyspark/rdd.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py index 41ea6e6e14..fb144bc45d 100644 --- a/python/pyspark/rdd.py +++ b/python/pyspark/rdd.py @@ -748,8 +748,10 @@ def _test(): # The small batch size here ensures that we see multiple batches, # even in these small test examples: globs['sc'] = SparkContext('local[4]', 'PythonTest', batchSize=2) - doctest.testmod(globs=globs) + (failure_count, test_count) = doctest.testmod(globs=globs) globs['sc'].stop() + if failure_count: + exit(-1) if __name__ == "__main__": |