Add log

apache · Dec 7, 2016 · ae3d42c · ae3d42c
1 parent 2cd4282
commit ae3d42c
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala
@@ -1769,7 +1769,13 @@ class SparkContext(config: SparkConf) extends Logging {
       setDaemon(true)
 
       override def run(): Unit = {
-        SparkContext.this.stop()
+        try {
+          SparkContext.this.stop()
+        } catch {
+          case e: Throwable =>
+            logError(e.getMessage, e)
+            throw e
+        }
       }
     }.start()
   }