diff options
| author | Sean Owen <sowen@cloudera.com> | 2014-10-01 11:28:22 -0700 |
|---|---|---|
| committer | Josh Rosen <joshrosen@apache.org> | 2014-10-01 11:28:22 -0700 |
| commit | dcb2f73f1cf1f6efd5175267e135ad6cf4bf6e3d (patch) | |
| tree | 3722ed4f7abbff0587f584f827e98cc10ead4897 /examples/src/main/python | |
| parent | abf588f47a26d0066f0b75d52b200a87bb085064 (diff) | |
| download | spark-dcb2f73f1cf1f6efd5175267e135ad6cf4bf6e3d.tar.gz spark-dcb2f73f1cf1f6efd5175267e135ad6cf4bf6e3d.tar.bz2 spark-dcb2f73f1cf1f6efd5175267e135ad6cf4bf6e3d.zip | |
SPARK-2626 [DOCS] Stop SparkContext in all examples
Call SparkContext.stop() in all examples (and touch up minor nearby code style issues while at it)
Author: Sean Owen <sowen@cloudera.com>
Closes #2575 from srowen/SPARK-2626 and squashes the following commits:
5b2baae [Sean Owen] Call SparkContext.stop() in all examples (and touch up minor nearby code style issues while at it)
Diffstat (limited to 'examples/src/main/python')
| -rw-r--r-- | examples/src/main/python/avro_inputformat.py | 2 | ||||
| -rw-r--r-- | examples/src/main/python/parquet_inputformat.py | 2 |
2 files changed, 4 insertions, 0 deletions
diff --git a/examples/src/main/python/avro_inputformat.py b/examples/src/main/python/avro_inputformat.py index cfda8d8327..4626bbb7e3 100644 --- a/examples/src/main/python/avro_inputformat.py +++ b/examples/src/main/python/avro_inputformat.py @@ -78,3 +78,5 @@ if __name__ == "__main__": output = avro_rdd.map(lambda x: x[0]).collect() for k in output: print k + + sc.stop() diff --git a/examples/src/main/python/parquet_inputformat.py b/examples/src/main/python/parquet_inputformat.py index c9b08f878a..fa4c20ab20 100644 --- a/examples/src/main/python/parquet_inputformat.py +++ b/examples/src/main/python/parquet_inputformat.py @@ -57,3 +57,5 @@ if __name__ == "__main__": output = parquet_rdd.map(lambda x: x[1]).collect() for k in output: print k + + sc.stop() |