Skip to content

Commit 385b6d2

Browse files
committed
Added link feature
1 parent ba1ac3e commit 385b6d2

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

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

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -177,6 +177,10 @@ function drawTaskAssignmentTimeline(groupArray, eventObjArray, minLaunchTime, zo
177177
return taskIdx;
178178
};
179179

180+
$(this).click(function() {
181+
window.location.href = "#task-" + getTaskIdx(this);
182+
});
183+
180184
$(this).hover(
181185
function() {
182186
var id = getTaskIdx(this);

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -535,7 +535,7 @@ private[ui] class StagePage(parent: StagesTab) extends WebUIPage("stage") {
535535
val executorComputingTime = metricsOpt.map(_.executorRunTime).getOrElse(0L) -
536536
shuffleReadTime - shuffleWriteTime
537537
val executorComputingTimeProportion =
538-
(executorComputingTime / totalExecutionTime * 100).toLong
538+
(executorComputingTime.toDouble / totalExecutionTime * 100).toLong
539539
val serializationTime = metricsOpt.map(_.resultSerializationTime).getOrElse(0L)
540540
val serializationTimeProportion =
541541
(serializationTime.toDouble / totalExecutionTime * 100).toLong
@@ -739,7 +739,7 @@ private[ui] class StagePage(parent: StagesTab) extends WebUIPage("stage") {
739739
val diskBytesSpilledSortable = maybeDiskBytesSpilled.map(_.toString).getOrElse("")
740740
val diskBytesSpilledReadable = maybeDiskBytesSpilled.map(Utils.bytesToString).getOrElse("")
741741

742-
<tr>
742+
<tr id={"task-" + info.index}>
743743
<td>{info.index}</td>
744744
<td>{info.taskId}</td>
745745
<td sorttable_customkey={info.attempt.toString}>{

0 commit comments

Comments
 (0)