diff options
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() |