You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2016/02/25 13:18:47 UTC
spark git commit: [SPARK-13117][WEB UI] WebUI should use the local ip
not 0.0.0.0
Repository: spark
Updated Branches:
refs/heads/master 2b2c8c332 -> 2e44031fa
[SPARK-13117][WEB UI] WebUI should use the local ip not 0.0.0.0
Fixed the HTTP Server Host Name/IP issue i.e. HTTP Server to take the
configured host name/IP and not '0.0.0.0' always.
Author: Devaraj K <de...@apache.org>
Closes #11133 from devaraj-kavali/SPARK-13117.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/2e44031f
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/2e44031f
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/2e44031f
Branch: refs/heads/master
Commit: 2e44031fafdb8cf486573b98e4faa6b31ffb90a4
Parents: 2b2c8c3
Author: Devaraj K <de...@apache.org>
Authored: Thu Feb 25 12:18:43 2016 +0000
Committer: Sean Owen <so...@cloudera.com>
Committed: Thu Feb 25 12:18:43 2016 +0000
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/ui/WebUI.scala | 2 +-
.../scala/org/apache/spark/deploy/LogUrlsStandaloneSuite.scala | 3 ++-
2 files changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/2e44031f/core/src/main/scala/org/apache/spark/ui/WebUI.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/ui/WebUI.scala b/core/src/main/scala/org/apache/spark/ui/WebUI.scala
index fe4949b..e515916 100644
--- a/core/src/main/scala/org/apache/spark/ui/WebUI.scala
+++ b/core/src/main/scala/org/apache/spark/ui/WebUI.scala
@@ -134,7 +134,7 @@ private[spark] abstract class WebUI(
def bind() {
assert(!serverInfo.isDefined, "Attempted to bind %s more than once!".format(className))
try {
- serverInfo = Some(startJettyServer("0.0.0.0", port, sslOptions, handlers, conf, name))
+ serverInfo = Some(startJettyServer(publicHostName, port, sslOptions, handlers, conf, name))
logInfo("Started %s at http://%s:%d".format(className, publicHostName, boundPort))
} catch {
case e: Exception =>
http://git-wip-us.apache.org/repos/asf/spark/blob/2e44031f/core/src/test/scala/org/apache/spark/deploy/LogUrlsStandaloneSuite.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/org/apache/spark/deploy/LogUrlsStandaloneSuite.scala b/core/src/test/scala/org/apache/spark/deploy/LogUrlsStandaloneSuite.scala
index f416ace..972b552 100644
--- a/core/src/test/scala/org/apache/spark/deploy/LogUrlsStandaloneSuite.scala
+++ b/core/src/test/scala/org/apache/spark/deploy/LogUrlsStandaloneSuite.scala
@@ -26,6 +26,7 @@ import org.apache.spark.{LocalSparkContext, SparkConf, SparkContext, SparkFunSui
import org.apache.spark.scheduler.{SparkListener, SparkListenerExecutorAdded}
import org.apache.spark.scheduler.cluster.ExecutorInfo
import org.apache.spark.util.SparkConfWithEnv
+import org.apache.spark.util.Utils
class LogUrlsStandaloneSuite extends SparkFunSuite with LocalSparkContext {
@@ -53,7 +54,7 @@ class LogUrlsStandaloneSuite extends SparkFunSuite with LocalSparkContext {
}
test("verify that log urls reflect SPARK_PUBLIC_DNS (SPARK-6175)") {
- val SPARK_PUBLIC_DNS = "public_dns"
+ val SPARK_PUBLIC_DNS = Utils.localHostNameForURI()
val conf = new SparkConfWithEnv(Map("SPARK_PUBLIC_DNS" -> SPARK_PUBLIC_DNS)).set(
"spark.extraListeners", classOf[SaveExecutorInfo].getName)
sc = new SparkContext("local-cluster[2,1,1024]", "test", conf)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org