Last active
February 10, 2020 16:46
-
-
Save SteadBytes/b206335c8e2429486a13421b7cfcdc88 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/core/src/main/scala/org/apache/spark/SparkEnv.scala b/core/src/main/scala/org/apache/spark/SparkEnv.scala | |
index 72123f2232..a10c027e2f 100644 | |
--- a/core/src/main/scala/org/apache/spark/SparkEnv.scala | |
+++ b/core/src/main/scala/org/apache/spark/SparkEnv.scala | |
@@ -175,7 +175,7 @@ object SparkEnv extends Logging { | |
create( | |
conf, | |
SparkContext.DRIVER_IDENTIFIER, | |
- bindAddress, | |
+ null, | |
advertiseAddress, | |
Option(port), | |
isLocal, | |
@@ -200,7 +200,7 @@ object SparkEnv extends Logging { | |
val env = create( | |
conf, | |
executorId, | |
- hostname, | |
+ null, | |
hostname, | |
None, | |
isLocal, | |
diff --git a/core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala b/core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala | |
index de2cc56bc6..f0218b1427 100644 | |
--- a/core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala | |
+++ b/core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala | |
@@ -40,7 +40,7 @@ private[spark] object RpcEnv { | |
conf: SparkConf, | |
securityManager: SecurityManager, | |
clientMode: Boolean = false): RpcEnv = { | |
- create(name, host, host, port, conf, securityManager, 0, clientMode) | |
+ create(name, null, host, port, conf, securityManager, 0, clientMode) | |
} | |
def create( |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment