diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2014-05-14 21:13:41 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-05-14 21:13:41 -0700 |
| commit | ad4e60ee7e2c49c24a9972312915f7f7253c7679 (patch) | |
| tree | 15cbda1094de4227f4ff13408781989dcec27011 /core | |
| parent | 2f639957f0bf70dddf1e698aa9e26007fb58bc67 (diff) | |
| download | spark-ad4e60ee7e2c49c24a9972312915f7f7253c7679.tar.gz spark-ad4e60ee7e2c49c24a9972312915f7f7253c7679.tar.bz2 spark-ad4e60ee7e2c49c24a9972312915f7f7253c7679.zip | |
[SPARK-1840] SparkListenerBus prints out scary error message when terminated normally
Running SparkPi example gave this error.
```
Pi is roughly 3.14374
14/05/14 18:16:19 ERROR Utils: Uncaught exception in thread SparkListenerBus
scala.runtime.NonLocalReturnControl$mcV$sp
```
This is due to the catch-all in the SparkListenerBus, which logged control throwable used by scala system
Author: Tathagata Das <tathagata.das1565@gmail.com>
Closes #783 from tdas/controlexception-fix and squashes the following commits:
a466c8d [Tathagata Das] Ignored control exceptions when logging all exceptions.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/util/Utils.scala | 2 |
1 files changed, 2 insertions, 0 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 index d041bfa66a..388f722242 100644 --- a/core/src/main/scala/org/apache/spark/util/Utils.scala +++ b/core/src/main/scala/org/apache/spark/util/Utils.scala @@ -1149,6 +1149,8 @@ private[spark] object Utils extends Logging { try { f } catch { + case ct: ControlThrowable => + throw ct case t: Throwable => logError(s"Uncaught exception in thread ${Thread.currentThread().getName}", t) throw t |