Repository: spark Updated Branches: refs/heads/master 9f02d7dc5 -> 366376425
[WEB-UI] Add count in fair scheduler pool page ## What changes were proposed in this pull request? Add count in fair scheduler pool page. The purpose is to know the statistics clearly. For specific reasons, please refer to PR of https://github.com/apache/spark/pull/18525 fix before:   fix after:   ## How was this patch tested? (Please explain how this patch was tested. E.g. unit tests, integration tests, manual tests) (If this patch involves UI changes, please attach a screenshot; otherwise, remove this) Please review http://spark.apache.org/contributing.html before opening a pull request. Author: guoxiaolong <[email protected]> Closes #19507 from guoxiaolongzte/add_count_in_fair_scheduler_pool_page. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/36637642 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/36637642 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/36637642 Branch: refs/heads/master Commit: 3663764254615cef442d4af55c11808445e5b03a Parents: 9f02d7d Author: guoxiaolong <[email protected]> Authored: Mon Oct 30 12:14:38 2017 +0000 Committer: Sean Owen <[email protected]> Committed: Mon Oct 30 12:14:38 2017 +0000 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/ui/jobs/AllStagesPage.scala | 2 +- core/src/main/scala/org/apache/spark/ui/jobs/PoolPage.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/36637642/core/src/main/scala/org/apache/spark/ui/jobs/AllStagesPage.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/AllStagesPage.scala b/core/src/main/scala/org/apache/spark/ui/jobs/AllStagesPage.scala index a30c135..dc5b03c 100644 --- a/core/src/main/scala/org/apache/spark/ui/jobs/AllStagesPage.scala +++ b/core/src/main/scala/org/apache/spark/ui/jobs/AllStagesPage.scala @@ -113,7 +113,7 @@ private[ui] class AllStagesPage(parent: StagesTab) extends WebUIPage("") { var content = summary ++ { if (sc.isDefined && isFairScheduler) { - <h4>{pools.size} Fair Scheduler Pools</h4> ++ poolTable.toNodeSeq + <h4>Fair Scheduler Pools ({pools.size})</h4> ++ poolTable.toNodeSeq } else { Seq.empty[Node] } http://git-wip-us.apache.org/repos/asf/spark/blob/36637642/core/src/main/scala/org/apache/spark/ui/jobs/PoolPage.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/PoolPage.scala b/core/src/main/scala/org/apache/spark/ui/jobs/PoolPage.scala index 819fe57..4b8c7b2 100644 --- a/core/src/main/scala/org/apache/spark/ui/jobs/PoolPage.scala +++ b/core/src/main/scala/org/apache/spark/ui/jobs/PoolPage.scala @@ -57,7 +57,7 @@ private[ui] class PoolPage(parent: StagesTab) extends WebUIPage("pool") { var content = <h4>Summary </h4> ++ poolTable.toNodeSeq if (shouldShowActiveStages) { - content ++= <h4>{activeStages.size} Active Stages</h4> ++ activeStagesTable.toNodeSeq + content ++= <h4>Active Stages ({activeStages.size})</h4> ++ activeStagesTable.toNodeSeq } UIUtils.headerSparkPage("Fair Scheduler Pool: " + poolName, content, parent) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
