diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/ui/ExecutionPage.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/ui/ExecutionPage.scala
index f0b56c2eb7a53..a4dbd2e1978d0 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/execution/ui/ExecutionPage.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/ui/ExecutionPage.scala
@@ -74,16 +74,14 @@ private[sql] class ExecutionPage(parent: SQLTab) extends WebUIPage("execution")
}}
}}
-
- Detail:
- {executionUIData.physicalPlanDescription}
-
val metrics = listener.getExecutionMetrics(executionId)
- summary ++ planVisualization(metrics, executionUIData.physicalPlanGraph)
+ summary ++
+ planVisualization(metrics, executionUIData.physicalPlanGraph) ++
+ physicalPlanDescription(executionUIData.physicalPlanDescription)
}.getOrElse {
No information to display for Plan {executionId}
}
@@ -124,4 +122,23 @@ private[sql] class ExecutionPage(parent: SQLTab) extends WebUIPage("execution")
private def jobURL(jobId: Long): String =
"%s/jobs/job?id=%s".format(UIUtils.prependBaseUri(parent.basePath), jobId)
+
+ private def physicalPlanDescription(physicalPlanDescription: String): Seq[Node] = {
+
+
+
{physicalPlanDescription}
+
+
+
+ }
}