Skip to content

Instantly share code, notes, and snippets.

@SteadBytes
Last active February 10, 2020 16:46
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save SteadBytes/b206335c8e2429486a13421b7cfcdc88 to your computer and use it in GitHub Desktop.
Save SteadBytes/b206335c8e2429486a13421b7cfcdc88 to your computer and use it in GitHub Desktop.
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