diff options
author | Patrick Wendell <pwendell@gmail.com> | 2013-07-01 09:19:45 -0700 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2013-07-01 09:19:45 -0700 |
commit | 5de326db7d5235dbf259a4c8b388cb24c40fd2ec (patch) | |
tree | 858293dd2c962c1ac11d61b770cb90dc2b2ccba0 /core/src/main | |
parent | e721ff7e5a2d738750c40e95d6ba53898eaa7051 (diff) | |
download | spark-5de326db7d5235dbf259a4c8b388cb24c40fd2ec.tar.gz spark-5de326db7d5235dbf259a4c8b388cb24c40fd2ec.tar.bz2 spark-5de326db7d5235dbf259a4c8b388cb24c40fd2ec.zip |
Print exception message
Diffstat (limited to 'core/src/main')
-rw-r--r-- | core/src/main/scala/spark/scheduler/SparkListener.scala | 1 | ||||
-rw-r--r-- | core/src/main/scala/spark/ui/jobs/StagePage.scala | 6 |
2 files changed, 6 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/scheduler/SparkListener.scala b/core/src/main/scala/spark/scheduler/SparkListener.scala index bac984b5c9..8de3aa91a4 100644 --- a/core/src/main/scala/spark/scheduler/SparkListener.scala +++ b/core/src/main/scala/spark/scheduler/SparkListener.scala @@ -68,6 +68,7 @@ class StatsReportListener extends SparkListener with Logging { showBytesDistribution("task result size:", (_, metric) => Some(metric.resultSize)) //runtime breakdown + val runtimePcts = stageCompleted.stageInfo.taskInfos.map{ case (info, metrics) => RuntimePercentage(info.duration, metrics) } diff --git a/core/src/main/scala/spark/ui/jobs/StagePage.scala b/core/src/main/scala/spark/ui/jobs/StagePage.scala index ed96fc2994..c6f87fc652 100644 --- a/core/src/main/scala/spark/ui/jobs/StagePage.scala +++ b/core/src/main/scala/spark/ui/jobs/StagePage.scala @@ -102,7 +102,11 @@ private[spark] class StagePage(parent: JobProgressUI) { {Option(metrics).flatMap{m => m.shuffleWriteMetrics}.map{s => <td>{Utils.memoryBytesToString(s.shuffleBytesWritten)}</td>}.getOrElse("")} <td>{exception.map(e => - <span>{e.className}<br/>{fmtStackTrace(e.stackTrace)}</span>).getOrElse("")}</td> + <span> + {e.className} ({e.description})<br/> + {fmtStackTrace(e.stackTrace)} + </span>).getOrElse("")} + </td> </tr> } } |