[SPARK-2435] Add shutdown hook to pyspark

apache · Aug 28, 2014 · ee0ee99 · ee0ee99
1 parent 76e3ba4
commit ee0ee99
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/python/pyspark/shell.py b/python/pyspark/shell.py
@@ -28,6 +28,7 @@
     sys.exit(1)
 
 
+import atexit
 import os
 import platform
 import pyspark
@@ -42,6 +43,7 @@
     SparkContext.setSystemProperty("spark.executor.uri", os.environ["SPARK_EXECUTOR_URI"])
 
 sc = SparkContext(appName="PySparkShell", pyFiles=add_files)
+atexit.register(lambda: sc.stop())
 
 print("""Welcome to
       ____              __