From 254a93073067c4febeb4903a06a1b7e26e17c67e Mon Sep 17 00:00:00 2001
From: Karen Feng <karenfeng.us@gmail.com>
Date: Tue, 6 Aug 2013 14:18:38 -0700
Subject: [PATCH] Reverse sorts StageTable by submitted time
---
core/src/main/scala/spark/ui/jobs/StageTable.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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. */
--
GitLab