diff options
| author | zsxwing <zsxwing@gmail.com> | 2015-02-27 13:31:46 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-02-27 13:31:46 +0000 |
| commit | e747e98490f8ede23b0a9e0795e7445d0b597624 (patch) | |
| tree | 7ef169d22c9d78b83198b608ee6ebc4b9375394a /yarn | |
| parent | 8cd1692c9092150107bed27777951633cbf945f6 (diff) | |
| download | spark-e747e98490f8ede23b0a9e0795e7445d0b597624.tar.gz spark-e747e98490f8ede23b0a9e0795e7445d0b597624.tar.bz2 spark-e747e98490f8ede23b0a9e0795e7445d0b597624.zip | |
[SPARK-6058][Yarn] Log the user class exception in ApplicationMaster
Because ApplicationMaster doesn't set SparkUncaughtExceptionHandler, the exception in the user class won't be logged. This PR added a `logError` for it.
Author: zsxwing <zsxwing@gmail.com>
Closes #4813 from zsxwing/SPARK-6058 and squashes the following commits:
806c932 [zsxwing] Log the user class exception
Diffstat (limited to 'yarn')
| -rw-r--r-- | yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala b/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala index 20fc19166a..796422bc25 100644 --- a/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala +++ b/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala @@ -486,11 +486,10 @@ private[spark] class ApplicationMaster( case _: InterruptedException => // Reporter thread can interrupt to stop user class case cause: Throwable => + logError("User class threw exception: " + cause.getMessage, cause) finish(FinalApplicationStatus.FAILED, ApplicationMaster.EXIT_EXCEPTION_USER_CLASS, "User class threw exception: " + cause.getMessage) - // re-throw to get it logged - throw cause } } } |