diff --git a/core/src/main/scala/org/apache/spark/network/nio/ConnectionManager.scala b/core/src/main/scala/org/apache/spark/network/nio/ConnectionManager.scala index df4b085d2251e..4dbf4b11751a6 100644 --- a/core/src/main/scala/org/apache/spark/network/nio/ConnectionManager.scala +++ b/core/src/main/scala/org/apache/spark/network/nio/ConnectionManager.scala @@ -167,7 +167,7 @@ private[nio] class ConnectionManager( Utils.startServiceOnPort[ServerSocketChannel](port, startService, name) serverChannel.register(selector, SelectionKey.OP_ACCEPT) - val id = new ConnectionManagerId(Utils.localHostName, serverChannel.socket.getLocalPort) + val id = new ConnectionManagerId(Utils.localIpAddress, serverChannel.socket.getLocalPort) logInfo("Bound socket to port " + serverChannel.socket.getLocalPort() + " with id = " + id) // used in combination with the ConnectionManagerId to create unique Connection ids