aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authormbautin <mbautin@gmail.com>2012-11-19 11:52:10 -0800
committermbautin <mbautin@gmail.com>2012-11-19 11:52:10 -0800
commit00f4e3ff9c5d7cf36c00ea66c9610d457670d2a0 (patch)
tree415fd53ebe8c763f792a96c6d7bb328ecf1a5f74
parent1f5a7e0e647c15be54a8cce0e2f5f3f83d4ea541 (diff)
downloadspark-00f4e3ff9c5d7cf36c00ea66c9610d457670d2a0.tar.gz
spark-00f4e3ff9c5d7cf36c00ea66c9610d457670d2a0.tar.bz2
spark-00f4e3ff9c5d7cf36c00ea66c9610d457670d2a0.zip
Addressing Matei's comment: SPARK_LOCAL_IP environment variable
-rw-r--r--core/src/main/scala/spark/Utils.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/Utils.scala b/core/src/main/scala/spark/Utils.scala
index 9805105ea8..c8799e6de3 100644
--- a/core/src/main/scala/spark/Utils.scala
+++ b/core/src/main/scala/spark/Utils.scala
@@ -200,7 +200,7 @@ 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 = {
- val defaultIpOverride = System.getenv("SPARK_DEFAULT_LOCAL_IP")
+ val defaultIpOverride = System.getenv("SPARK_LOCAL_IP")
if (defaultIpOverride != null)
defaultIpOverride
else