Repository: spark
Updated Branches:
  refs/heads/branch-2.3 8db935f97 -> 306e881b6


[SPARK-24704][WEBUI] Fix the order of stages in the DAG graph

## What changes were proposed in this pull request?

Before:

![wx20180630-155537](https://user-images.githubusercontent.com/1438757/42123357-2c2e2d84-7c83-11e8-8abd-1c2860f38783.png)

After:

![wx20180630-155604](https://user-images.githubusercontent.com/1438757/42123359-32fae990-7c83-11e8-8a7b-cdcee94f9123.png)

## How was this patch tested?

Manual tests.

Author: Stan Zhai <[email protected]>

Closes #21680 from stanzhai/fix-dag-graph.

(cherry picked from commit 772060d0940a97d89807befd682a70ae82e83ef4)
Signed-off-by: Marcelo Vanzin <[email protected]>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/306e881b
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/306e881b
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/306e881b

Branch: refs/heads/branch-2.3
Commit: 306e881b62eb112f8014219098eb97f7cbe75e98
Parents: 8db935f
Author: Stan Zhai <[email protected]>
Authored: Wed Jul 4 10:12:36 2018 +0200
Committer: Marcelo Vanzin <[email protected]>
Committed: Tue Aug 28 10:38:03 2018 -0700

----------------------------------------------------------------------
 core/src/main/scala/org/apache/spark/status/AppStatusStore.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/306e881b/core/src/main/scala/org/apache/spark/status/AppStatusStore.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/status/AppStatusStore.scala 
b/core/src/main/scala/org/apache/spark/status/AppStatusStore.scala
index 688f25a..e237281 100644
--- a/core/src/main/scala/org/apache/spark/status/AppStatusStore.scala
+++ b/core/src/main/scala/org/apache/spark/status/AppStatusStore.scala
@@ -471,7 +471,7 @@ private[spark] class AppStatusStore(
 
   def operationGraphForJob(jobId: Int): Seq[RDDOperationGraph] = {
     val job = store.read(classOf[JobDataWrapper], jobId)
-    val stages = job.info.stageIds
+    val stages = job.info.stageIds.sorted
 
     stages.map { id =>
       val g = store.read(classOf[RDDOperationGraphWrapper], 
id).toRDDOperationGraph()


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to