throw fatal error again

prabeesh · Mar 18, 2015 · 589276a · 589276a
1 parent 3c72cd8
commit 589276a
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/util/Utils.scala b/core/src/main/scala/org/apache/spark/util/Utils.scala
@@ -1171,11 +1171,15 @@ private[spark] object Utils extends Logging {
     } catch {
       case e: ControlThrowable => throw e
       case t: Throwable =>
+        val currentThreadName = Thread.currentThread().getName
         if (sc != null) {
-          logError(s"uncaught error in thread ${Thread.currentThread().getName}, stopping " +
-            "SparkContext", t)
+          logError(s"uncaught error in thread $currentThreadName, stopping SparkContext", t)
           sc.stop()
         }
+        if (!NonFatal(t)) {
+          logError(s"throw uncaught fatal error in thread $currentThreadName", t)
+          throw t
+        }
     }
   }