File tree Expand file tree Collapse file tree 1 file changed +1
-1
lines changed
core/src/main/scala/org/apache/spark/ui/jobs Expand file tree Collapse file tree 1 file changed +1
-1
lines changed Original file line number Diff line number Diff 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
You can’t perform that action at this time.
0 commit comments