diff options
| author | mbautin <mbautin@gmail.com> | 2012-11-15 13:44:13 -0800 |
|---|---|---|
| committer | mbautin <mbautin@gmail.com> | 2012-11-15 13:57:47 -0800 |
| commit | 1f5a7e0e647c15be54a8cce0e2f5f3f83d4ea541 (patch) | |
| tree | 2b7e9ca56f4f864202fd83bcc6f56a3d737771a5 /core | |
| parent | c23a74df0ab1ab105a3ad6b70e93bc0aa614771d (diff) | |
| download | spark-1f5a7e0e647c15be54a8cce0e2f5f3f83d4ea541.tar.gz spark-1f5a7e0e647c15be54a8cce0e2f5f3f83d4ea541.tar.bz2 spark-1f5a7e0e647c15be54a8cce0e2f5f3f83d4ea541.zip | |
SPARK-624: make the default local IP customizable
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/Utils.scala | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/Utils.scala b/core/src/main/scala/spark/Utils.scala index 567c4b1475..9805105ea8 100644 --- a/core/src/main/scala/spark/Utils.scala +++ b/core/src/main/scala/spark/Utils.scala @@ -199,7 +199,13 @@ private object Utils extends Logging { /** * Get the local host's IP address in dotted-quad format (e.g. 1.2.3.4). */ - def localIpAddress(): String = InetAddress.getLocalHost.getHostAddress + def localIpAddress(): String = { + val defaultIpOverride = System.getenv("SPARK_DEFAULT_LOCAL_IP") + if (defaultIpOverride != null) + defaultIpOverride + else + InetAddress.getLocalHost.getHostAddress + } private var customHostname: Option[String] = None |