File tree Expand file tree Collapse file tree 1 file changed +3
-5
lines changed
core/src/main/scala/org/apache/spark/ui/jobs Expand file tree Collapse file tree 1 file changed +3
-5
lines changed Original file line number Diff line number Diff line change @@ -513,7 +513,6 @@ private[ui] class StagePage(parent: StagesTab) extends WebUIPage("stage") {
513513 val executorsSet = new HashSet [(String , String )]
514514 var minLaunchTime = Long .MaxValue
515515 var maxFinishTime = Long .MinValue
516- var numEffectiveTasks = 0
517516
518517 val executorsArrayStr =
519518 tasks.sortBy(- _.taskInfo.launchTime).take(MAX_TIMELINE_TASKS ).map { taskUIData =>
@@ -537,7 +536,6 @@ private[ui] class StagePage(parent: StagesTab) extends WebUIPage("stage") {
537536 val totalExecutionTime = finishTime - launchTime
538537 minLaunchTime = launchTime.min(minLaunchTime)
539538 maxFinishTime = launchTime.max(maxFinishTime)
540- numEffectiveTasks += 1
541539
542540 def toProportion (time : Long ) = (time.toDouble / totalExecutionTime * 100 ).toLong
543541
@@ -653,11 +651,11 @@ private[ui] class StagePage(parent: StagesTab) extends WebUIPage("stage") {
653651 </span > ++
654652 <div id =" task-assignment-timeline" class =" collapsed" >
655653 {
656- if (MAX_TIMELINE_TASKS < numEffectiveTasks ) {
654+ if (MAX_TIMELINE_TASKS < tasks.size ) {
657655 <strong >
658656 This stage has more than the maximum number of tasks that can be shown in the
659- visualization! Only the first {MAX_TIMELINE_TASKS } tasks
660- (of {numEffectiveTasks } total) are shown.
657+ visualization! Only the most recent {MAX_TIMELINE_TASKS } tasks
658+ (of {tasks.size } total) are shown.
661659 </strong >
662660 } else {
663661 Seq .empty
You can’t perform that action at this time.
0 commit comments