diff options
Diffstat (limited to 'examples/src/main/python/cassandra_inputformat.py')
| -rw-r--r-- | examples/src/main/python/cassandra_inputformat.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/examples/src/main/python/cassandra_inputformat.py b/examples/src/main/python/cassandra_inputformat.py index 39fa6b0d22..e4a897f61e 100644 --- a/examples/src/main/python/cassandra_inputformat.py +++ b/examples/src/main/python/cassandra_inputformat.py @@ -77,3 +77,5 @@ if __name__ == "__main__": output = cass_rdd.collect() for (k, v) in output: print (k, v) + + sc.stop() |