diff options
author | ph <ph@plista.com> | 2015-10-17 15:37:51 -0700 |
---|---|---|
committer | Josh Rosen <joshrosen@databricks.com> | 2015-10-17 15:37:51 -0700 |
commit | 022a8f6a1f7cb477a65a65482982c021ce08a73c (patch) | |
tree | 91397badedc965514cea68de4a10012dd44ffc27 /core | |
parent | 57f83e36d63bbd79663c49a6c1e8f6c3c8fe4789 (diff) | |
download | spark-022a8f6a1f7cb477a65a65482982c021ce08a73c.tar.gz spark-022a8f6a1f7cb477a65a65482982c021ce08a73c.tar.bz2 spark-022a8f6a1f7cb477a65a65482982c021ce08a73c.zip |
[SPARK-11129] [MESOS] Link Spark WebUI from Mesos WebUI
Mesos has a feature for linking to frameworks running on top of Mesos
from the Mesos WebUI. This commit enables Spark to make use of this
feature so one can directly visit the running Spark WebUIs from the
Mesos WebUI.
Author: ph <ph@plista.com>
Closes #9135 from philipphoffmann/SPARK-11129.
Diffstat (limited to 'core')
2 files changed, 12 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackend.scala b/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackend.scala index 65cb5016cf..d10a77f8e5 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackend.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackend.scala @@ -127,7 +127,12 @@ private[spark] class CoarseMesosSchedulerBackend( override def start() { super.start() val driver = createSchedulerDriver( - master, CoarseMesosSchedulerBackend.this, sc.sparkUser, sc.appName, sc.conf) + master, + CoarseMesosSchedulerBackend.this, + sc.sparkUser, + sc.appName, + sc.conf, + sc.ui.map(_.appUIAddress)) startScheduler(driver) } diff --git a/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosSchedulerBackend.scala b/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosSchedulerBackend.scala index 8edf7007a5..6196176c7c 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosSchedulerBackend.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosSchedulerBackend.scala @@ -68,7 +68,12 @@ private[spark] class MesosSchedulerBackend( override def start() { classLoader = Thread.currentThread.getContextClassLoader val driver = createSchedulerDriver( - master, MesosSchedulerBackend.this, sc.sparkUser, sc.appName, sc.conf) + master, + MesosSchedulerBackend.this, + sc.sparkUser, + sc.appName, + sc.conf, + sc.ui.map(_.appUIAddress)) startScheduler(driver) } |