Skip to content

Commit d5f794a

Browse files
committed
Fixed performance issues more
1 parent 64e6642 commit d5f794a

File tree

2 files changed

+2
-19
lines changed

2 files changed

+2
-19
lines changed

core/src/main/resources/org/apache/spark/ui/static/timeline-view.js

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -154,11 +154,7 @@ function drawTaskAssignmentTimeline(groupArray, eventObjArray, minLaunchTime, zo
154154
taskTimeline.setOptions(options);
155155
taskTimeline.setGroups(groups);
156156
taskTimeline.setItems(items);
157-
var curEnd = taskTimeline.getWindow()["end"].getTime();
158-
if (curEnd - minLaunchTime > zoomMax) {
159-
curEnd = minLaunchTime + zoomMax;
160-
}
161-
taskTimeline.setWindow(minLaunchTime, curEnd);
157+
162158
taskTimeline.on("rangechange", function(prop) {
163159
if (currentDisplayedTooltip !== null) {
164160
$(currentDisplayedTooltip).tooltip("hide");

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

Lines changed: 1 addition & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -646,20 +646,7 @@ private[ui] class StagePage(parent: StagesTab) extends WebUIPage("stage") {
646646
"""
647647
}.mkString("[", ",", "]")
648648

649-
var maxWindowInSec = ((maxFinishTime - minLaunchTime) / 1000.0).round
650-
if (maxWindowInSec <= 0) maxWindowInSec = 1
651-
val tasksPerSecond = numEffectiveTasks / maxWindowInSec
652-
var maxZoom = {
653-
if (tasksPerSecond > 100) {
654-
1000L / (tasksPerSecond / 100)
655-
}
656-
else {
657-
1000 * (100 / tasksPerSecond)
658-
}
659-
}
660-
661-
if (maxZoom < 0) maxZoom = 1
662-
649+
val maxZoom = maxFinishTime - minLaunchTime
663650
<span class="expand-task-assignment-timeline">
664651
<span class="expand-task-assignment-timeline-arrow arrow-closed"></span>
665652
<a>Event Timeline {

0 commit comments

Comments
 (0)