File tree Expand file tree Collapse file tree 1 file changed +0
-2
lines changed
core/src/main/scala/org/apache/spark/ui/jobs Expand file tree Collapse file tree 1 file changed +0
-2
lines changed Original file line number Diff line number Diff line change @@ -288,7 +288,6 @@ private[ui] class StagePage(parent: JobProgressTab) extends WebUIPage("stage") {
288
288
val shuffleWriteSizes = validTasks.map { case TaskUIData (_, metrics, _) =>
289
289
metrics.get.shuffleWriteMetrics.map(_.shuffleBytesWritten).getOrElse(0L ).toDouble
290
290
}
291
-
292
291
val shuffleWriteQuantiles = <td >Shuffle Write </td > +:
293
292
getFormattedSizeQuantiles(shuffleWriteSizes)
294
293
@@ -362,7 +361,6 @@ private[ui] class StagePage(parent: JobProgressTab) extends WebUIPage("stage") {
362
361
val executorLaunchTime = metrics.map(_.executorLaunchTime).getOrElse(0L )
363
362
val taskDeserializationTime = metrics.map(_.executorDeserializeTime).getOrElse(0L )
364
363
val serializationTime = metrics.map(_.resultSerializationTime).getOrElse(0L )
365
-
366
364
val gettingResultTime = info.gettingResultTime
367
365
368
366
val maybeAccumulators = info.accumulables
You can’t perform that action at this time.
0 commit comments