Skip to content

Commit e327340

Browse files
committed
SPARK-4175. Exception on stage page
1 parent 087e31a commit e327340

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -312,7 +312,7 @@ private[ui] class StagePage(parent: JobProgressTab) extends WebUIPage("stage") {
312312
else metrics.map(_.executorRunTime).getOrElse(1L)
313313
val formatDuration = if (info.status == "RUNNING") UIUtils.formatDuration(duration)
314314
else metrics.map(m => UIUtils.formatDuration(m.executorRunTime)).getOrElse("")
315-
val schedulerDelay = getSchedulerDelay(info, metrics.get)
315+
val schedulerDelay = metrics.map(getSchedulerDelay(info, _)).getOrElse(0L)
316316
val gcTime = metrics.map(_.jvmGCTime).getOrElse(0L)
317317
val serializationTime = metrics.map(_.resultSerializationTime).getOrElse(0L)
318318
val gettingResultTime = info.gettingResultTime

0 commit comments

Comments
 (0)