aboutsummaryrefslogtreecommitdiff
path: root/yarn/common/src/main
diff options
context:
space:
mode:
authorwitgo <witgo@qq.com>2014-07-15 13:52:56 -0500
committerThomas Graves <tgraves@apache.org>2014-07-15 13:52:56 -0500
commit72ea56da8e383c61c6f18eeefef03b9af00f5158 (patch)
tree2bc7f4c045366d398b9fbdf38c00f0869514d675 /yarn/common/src/main
parent9dd635eb5df52835b3b7f4f2b9c789da9e813c71 (diff)
downloadspark-72ea56da8e383c61c6f18eeefef03b9af00f5158.tar.gz
spark-72ea56da8e383c61c6f18eeefef03b9af00f5158.tar.bz2
spark-72ea56da8e383c61c6f18eeefef03b9af00f5158.zip
SPARK-1291: Link the spark UI to RM ui in yarn-client mode
Author: witgo <witgo@qq.com> Closes #1112 from witgo/SPARK-1291 and squashes the following commits: 6022bcd [witgo] review commit 1fbb925 [witgo] add addAmIpFilter to yarn alpha 210299c [witgo] review commit 1b92a07 [witgo] review commit 6896586 [witgo] Add comments to addWebUIFilter 3e9630b [witgo] review commit 142ee29 [witgo] review commit 1fe7710 [witgo] Link the spark UI to RM ui in yarn-client mode
Diffstat (limited to 'yarn/common/src/main')
-rw-r--r--yarn/common/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala1
1 files changed, 1 insertions, 0 deletions
diff --git a/yarn/common/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala b/yarn/common/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala
index 0f9fdcfcb6..1b37c4bb13 100644
--- a/yarn/common/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala
+++ b/yarn/common/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala
@@ -48,6 +48,7 @@ private[spark] class YarnClientSchedulerBackend(
val driverHost = conf.get("spark.driver.host")
val driverPort = conf.get("spark.driver.port")
val hostport = driverHost + ":" + driverPort
+ conf.set("spark.driver.appUIAddress", sc.ui.appUIHostPort)
val argsArrayBuf = new ArrayBuffer[String]()
argsArrayBuf += (