aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorKaren Feng <karenfeng.us@gmail.com>2013-07-15 15:47:21 -0700
committerKaren Feng <karenfeng.us@gmail.com>2013-07-15 15:47:21 -0700
commit39557112501901da7f9b4be6159a5a0be5511b42 (patch)
treeeae4b9f4f9318b03cc85915f33901fec996498e9
parente3d3e6f0ab34f0fe083ef9feb31b9e9fd257519f (diff)
downloadspark-39557112501901da7f9b4be6159a5a0be5511b42.tar.gz
spark-39557112501901da7f9b4be6159a5a0be5511b42.tar.bz2
spark-39557112501901da7f9b4be6159a5a0be5511b42.zip
Added field to master UI with link to job UI
-rw-r--r--core/src/main/scala/spark/deploy/master/ui/IndexPage.scala7
1 files changed, 5 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/deploy/master/ui/IndexPage.scala b/core/src/main/scala/spark/deploy/master/ui/IndexPage.scala
index 7545ecf868..434f600e8e 100644
--- a/core/src/main/scala/spark/deploy/master/ui/IndexPage.scala
+++ b/core/src/main/scala/spark/deploy/master/ui/IndexPage.scala
@@ -26,8 +26,8 @@ private[spark] class IndexPage(parent: MasterWebUI) {
val workers = state.workers.sortBy(_.id)
val workerTable = UIUtils.listingTable(workerHeaders, workerRow, workers)
- val appHeaders = Seq("ID", "Description", "Cores", "Memory per Node", "Submit Time", "User",
- "State", "Duration")
+ val appHeaders = Seq("ID", "Job UI", "Description", "Cores", "Memory per Node", "Submit Time",
+ "User", "State", "Duration")
val activeApps = state.activeApps.sortBy(_.startTime).reverse
val activeAppsTable = UIUtils.listingTable(appHeaders, appRow, activeApps)
val completedApps = state.completedApps.sortBy(_.endTime).reverse
@@ -103,6 +103,9 @@ private[spark] class IndexPage(parent: MasterWebUI) {
<td>
<a href={"app?appId=" + app.id}>{app.id}</a>
</td>
+ <td>
+ <a href={app.appUiUrl}>{app.appUiUrl}</a>
+ </td>
<td>{app.desc.name}</td>
<td>
{app.coresGranted}