diff options
| author | Sandy Ryza <sandy@cloudera.com> | 2014-10-31 17:22:52 -0700 |
|---|---|---|
| committer | Kay Ousterhout <kayousterhout@gmail.com> | 2014-10-31 17:22:52 -0700 |
| commit | 23f73f525ce3d2b4a614e60f4f9170c860ab93da (patch) | |
| tree | e1314d8d00b512c196493e96313bcb15bcff1101 /core | |
| parent | 087e31a7a0550f520c2e21b0ceaf36b969e050b4 (diff) | |
| download | spark-23f73f525ce3d2b4a614e60f4f9170c860ab93da.tar.gz spark-23f73f525ce3d2b4a614e60f4f9170c860ab93da.tar.bz2 spark-23f73f525ce3d2b4a614e60f4f9170c860ab93da.zip | |
SPARK-4175. Exception on stage page
Author: Sandy Ryza <sandy@cloudera.com>
Closes #3043 from sryza/sandy-spark-4175 and squashes the following commits:
e327340 [Sandy Ryza] SPARK-4175. Exception on stage page
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala b/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala index bf45272aef..7cc03b7d33 100644 --- a/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala +++ b/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala @@ -312,7 +312,7 @@ private[ui] class StagePage(parent: JobProgressTab) extends WebUIPage("stage") { else metrics.map(_.executorRunTime).getOrElse(1L) val formatDuration = if (info.status == "RUNNING") UIUtils.formatDuration(duration) else metrics.map(m => UIUtils.formatDuration(m.executorRunTime)).getOrElse("") - val schedulerDelay = getSchedulerDelay(info, metrics.get) + val schedulerDelay = metrics.map(getSchedulerDelay(info, _)).getOrElse(0L) val gcTime = metrics.map(_.jvmGCTime).getOrElse(0L) val serializationTime = metrics.map(_.resultSerializationTime).getOrElse(0L) val gettingResultTime = info.gettingResultTime |