diff options
| author | Karen Feng <karenfeng.us@gmail.com> | 2013-08-06 14:18:38 -0700 |
|---|---|---|
| committer | Karen Feng <karenfeng.us@gmail.com> | 2013-08-06 14:18:38 -0700 |
| commit | 254a93073067c4febeb4903a06a1b7e26e17c67e (patch) | |
| tree | d08e454eaea5a61cc28dfb339ef0fc6ea7c75c99 /core | |
| parent | 5ed5b73026748223c44a83ac4e189e2cd5ab05aa (diff) | |
| download | spark-254a93073067c4febeb4903a06a1b7e26e17c67e.tar.gz spark-254a93073067c4febeb4903a06a1b7e26e17c67e.tar.bz2 spark-254a93073067c4febeb4903a06a1b7e26e17c67e.zip | |
Reverse sorts StageTable by submitted time
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/ui/jobs/StageTable.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/ui/jobs/StageTable.scala b/core/src/main/scala/spark/ui/jobs/StageTable.scala index b1b8743a97..658b25138d 100644 --- a/core/src/main/scala/spark/ui/jobs/StageTable.scala +++ b/core/src/main/scala/spark/ui/jobs/StageTable.scala @@ -25,7 +25,7 @@ private[spark] class StageTable(val stages: Seq[Stage], val parent: JobProgressU val isFairScheduler = listener.sc.getSchedulingMode == SchedulingMode.FAIR def toNodeSeq(): Seq[Node] = { - stageTable(stageRow, stages) + stageTable(stageRow, stages.sortBy(_.submissionTime).reverse) } /** Special table which merges two header cells. */ |