diff --git a/core/src/main/scala/org/apache/spark/deploy/master/ui/ApplicationPage.scala b/core/src/main/scala/org/apache/spark/deploy/master/ui/ApplicationPage.scala
index 80fe7344174f5..c1aee1d1fb427 100644
--- a/core/src/main/scala/org/apache/spark/deploy/master/ui/ApplicationPage.scala
+++ b/core/src/main/scala/org/apache/spark/deploy/master/ui/ApplicationPage.scala
@@ -96,15 +96,11 @@ private[spark] class ApplicationPage(parent: MasterWebUI) extends WebUIPage("app
Executor Summary
+ {executorsTable}
{
- executorsTable ++
- {
- if (removedExecutors.nonEmpty) {
- Removed Executors
++
- removedExecutorsTable
- } else {
- Seq.empty[Node]
- }
+ if (removedExecutors.nonEmpty) {
+ Removed Executors
++
+ removedExecutorsTable
}
}
diff --git a/core/src/main/scala/org/apache/spark/deploy/worker/ui/WorkerPage.scala b/core/src/main/scala/org/apache/spark/deploy/worker/ui/WorkerPage.scala
index d4513118ced05..4e8b46b43628c 100644
--- a/core/src/main/scala/org/apache/spark/deploy/worker/ui/WorkerPage.scala
+++ b/core/src/main/scala/org/apache/spark/deploy/worker/ui/WorkerPage.scala
@@ -47,73 +47,61 @@ private[spark] class WorkerPage(parent: WorkerWebUI) extends WebUIPage("") {
val workerState = Await.result(stateFuture, timeout)
val executorHeaders = Seq("ExecutorID", "Cores", "Memory", "Job Details", "Logs")
+ val runningExecutors = workerState.executors
val runningExecutorTable =
- UIUtils.listingTable(executorHeaders, executorRow, workerState.executors)
+ UIUtils.listingTable(executorHeaders, executorRow, runningExecutors)
+ val finishedExecutors = workerState.finishedExecutors
val finishedExecutorTable =
- UIUtils.listingTable(executorHeaders, executorRow, workerState.finishedExecutors)
+ UIUtils.listingTable(executorHeaders, executorRow, finishedExecutors)
val driverHeaders = Seq("DriverID", "Main Class", "State", "Cores", "Memory", "Logs", "Notes")
val runningDrivers = workerState.drivers.sortBy(_.driverId).reverse
val runningDriverTable = UIUtils.listingTable(driverHeaders, driverRow, runningDrivers)
val finishedDrivers = workerState.finishedDrivers.sortBy(_.driverId).reverse
- def finishedDriverTable = UIUtils.listingTable(driverHeaders, driverRow, finishedDrivers)
+ val finishedDriverTable = UIUtils.listingTable(driverHeaders, driverRow, finishedDrivers)
// For now we only show driver information if the user has submitted drivers to the cluster.
// This is until we integrate the notion of drivers and applications in the UI.
- def hasDrivers = runningDrivers.length > 0 || finishedDrivers.length > 0
val content =
-
-
-
- - ID: {workerState.workerId}
- -
- Master URL: {workerState.masterUrl}
-
- - Cores: {workerState.cores} ({workerState.coresUsed} Used)
- - Memory: {Utils.megabytesToString(workerState.memory)}
- ({Utils.megabytesToString(workerState.memoryUsed)} Used)
-
-
Back to Master
-
+
+
+
+ - ID: {workerState.workerId}
+ -
+ Master URL: {workerState.masterUrl}
+
+ - Cores: {workerState.cores} ({workerState.coresUsed} Used)
+ - Memory: {Utils.megabytesToString(workerState.memory)}
+ ({Utils.megabytesToString(workerState.memoryUsed)} Used)
+
+
Back to Master
-
-
-
-
Running Executors {workerState.executors.size}
- {runningExecutorTable}
-
-
- // scalastyle:off
-
- {if (hasDrivers)
-
-
-
Running Drivers {workerState.drivers.size}
- {runningDriverTable}
-
-
+
+
+
+
Running Executors ({runningExecutors.size})
+ {runningExecutorTable}
+ {
+ if (runningDrivers.nonEmpty) {
+ Running Drivers ({runningDrivers.size})
++
+ runningDriverTable
+ }
}
-
-
-
-
-
Finished Executors
- {finishedExecutorTable}
-
-
-
-
- {if (hasDrivers)
-
-
-
Finished Drivers
- {finishedDriverTable}
-
-
+ {
+ if (finishedExecutors.nonEmpty) {
+
Finished Executors ({finishedExecutors.size})
++
+ finishedExecutorTable
+ }
}
-
;
- // scalastyle:on
+ {
+ if (finishedDrivers.nonEmpty) {
+
Finished Drivers ({finishedDrivers.size})
++
+ finishedDriverTable
+ }
+ }
+
+
;
UIUtils.basicSparkPage(content, "Spark Worker at %s:%s".format(
workerState.host, workerState.port))
}