diff options
author | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-11-15 00:10:52 -0800 |
---|---|---|
committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-11-15 00:10:52 -0800 |
commit | c23a74df0ab1ab105a3ad6b70e93bc0aa614771d (patch) | |
tree | f0b584d41e7a6ce879b7cc012dcb4efd168357ef | |
parent | 59e648c08190056605002f5b79bc09b12919934a (diff) | |
download | spark-c23a74df0ab1ab105a3ad6b70e93bc0aa614771d.tar.gz spark-c23a74df0ab1ab105a3ad6b70e93bc0aa614771d.tar.bz2 spark-c23a74df0ab1ab105a3ad6b70e93bc0aa614771d.zip |
Use DNS names instead of IP addresses in standalone mode, to allow
matching with data locality hints from storage systems.
-rw-r--r-- | core/src/main/scala/spark/deploy/master/MasterArguments.scala | 4 | ||||
-rw-r--r-- | core/src/main/scala/spark/deploy/worker/WorkerArguments.scala | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/core/src/main/scala/spark/deploy/master/MasterArguments.scala b/core/src/main/scala/spark/deploy/master/MasterArguments.scala index 1b1c3dd0ad..4ceab3fc03 100644 --- a/core/src/main/scala/spark/deploy/master/MasterArguments.scala +++ b/core/src/main/scala/spark/deploy/master/MasterArguments.scala @@ -7,7 +7,7 @@ import spark.Utils * Command-line parser for the master. */ private[spark] class MasterArguments(args: Array[String]) { - var ip = Utils.localIpAddress() + var ip = Utils.localHostName() var port = 7077 var webUiPort = 8080 @@ -59,4 +59,4 @@ private[spark] class MasterArguments(args: Array[String]) { " --webui-port PORT Port for web UI (default: 8080)") System.exit(exitCode) } -}
\ No newline at end of file +} diff --git a/core/src/main/scala/spark/deploy/worker/WorkerArguments.scala b/core/src/main/scala/spark/deploy/worker/WorkerArguments.scala index 60dc107a4c..340920025b 100644 --- a/core/src/main/scala/spark/deploy/worker/WorkerArguments.scala +++ b/core/src/main/scala/spark/deploy/worker/WorkerArguments.scala @@ -9,7 +9,7 @@ import java.lang.management.ManagementFactory * Command-line parser for the master. */ private[spark] class WorkerArguments(args: Array[String]) { - var ip = Utils.localIpAddress() + var ip = Utils.localHostName() var port = 0 var webUiPort = 8081 var cores = inferDefaultCores() @@ -110,4 +110,4 @@ private[spark] class WorkerArguments(args: Array[String]) { // Leave out 1 GB for the operating system, but don't return a negative memory size math.max(totalMb - 1024, 512) } -}
\ No newline at end of file +} |