diff options
| author | Ryan Williams <ryan.blake.williams@gmail.com> | 2015-03-22 11:54:23 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-03-22 11:54:23 +0000 |
| commit | b9fe504b497cfa509310b4045de4873739c76667 (patch) | |
| tree | 8321f2e566e54533dba70a18fc0c624788076df7 /core | |
| parent | 9b1e1f20d4498bda72dd53a832110883a7ca41b5 (diff) | |
| download | spark-b9fe504b497cfa509310b4045de4873739c76667.tar.gz spark-b9fe504b497cfa509310b4045de4873739c76667.tar.bz2 spark-b9fe504b497cfa509310b4045de4873739c76667.zip | |
[SPARK-6448] Make history server log parse exceptions
This helped me to debug a parse error that was due to the event log format changing recently.
Author: Ryan Williams <ryan.blake.williams@gmail.com>
Closes #5122 from ryan-williams/histerror and squashes the following commits:
5831656 [Ryan Williams] line length
c3742ae [Ryan Williams] Make history server log parse exceptions
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala b/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala index 7fde020409..db7c499661 100644 --- a/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala +++ b/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala @@ -233,7 +233,8 @@ private[history] class FsHistoryProvider(conf: SparkConf) extends ApplicationHis } catch { case e: Exception => logError( - s"Exception encountered when attempting to load application log ${fileStatus.getPath}") + s"Exception encountered when attempting to load application log ${fileStatus.getPath}", + e) None } }.toSeq.sortWith(compareAppInfo) |