From 55aebe62affa74a5bb873fff0316baa0332982ff Mon Sep 17 00:00:00 2001 From: Shahid Date: Wed, 14 Nov 2018 02:00:20 +0530 Subject: [PATCH] Aggregated Metrics table sort based on executor ID --- .../apache/spark/ui/jobs/ExecutorTable.scala | 17 +++++++---------- 1 file changed, 7 insertions(+), 10 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/ExecutorTable.scala b/core/src/main/scala/org/apache/spark/ui/jobs/ExecutorTable.scala index 0ff64f053f371..d987959fbf77b 100644 --- a/core/src/main/scala/org/apache/spark/ui/jobs/ExecutorTable.scala +++ b/core/src/main/scala/org/apache/spark/ui/jobs/ExecutorTable.scala @@ -70,6 +70,7 @@ private[ui] class ExecutorTable(stage: StageData, store: AppStatusStore) { Blacklisted + Logs {createExecutorTable(stage)} @@ -92,16 +93,7 @@ private[ui] class ExecutorTable(stage: StageData, store: AppStatusStore) { executorSummary.toSeq.sortBy(_._1).map { case (k, v) => val executor = store.asOption(store.executorSummary(k)) - -
{k}
-
- { - executor.map(_.executorLogs).getOrElse(Map.empty).map { - case (logName, logUrl) =>
{logName}
- } - } -
- + k {executor.map { e => e.hostPort }.getOrElse("CANNOT FIND ADDRESS")} {UIUtils.formatDuration(v.taskTime)} {v.failedTasks + v.succeededTasks + v.killedTasks} @@ -145,6 +137,11 @@ private[ui] class ExecutorTable(stage: StageData, store: AppStatusStore) { false } } + {executor.map(_.executorLogs).getOrElse(Map.empty).map { + case (logName, logUrl) =>
{logName}
+ }} + + } }