diff options
| author | Kousuke Saruta <sarutak@oss.nttdata.co.jp> | 2014-08-20 14:04:39 -0700 |
|---|---|---|
| committer | Josh Rosen <joshrosen@apache.org> | 2014-08-20 14:04:39 -0700 |
| commit | c1ba4cd6b4db22a9325eee50dc40a78593a10de1 (patch) | |
| tree | 3fb99f8c7993151a15956ed3f848bbe4e28be0fd /core | |
| parent | 0ea46ac80089e9091d247704b17afbc423c0060d (diff) | |
| download | spark-c1ba4cd6b4db22a9325eee50dc40a78593a10de1.tar.gz spark-c1ba4cd6b4db22a9325eee50dc40a78593a10de1.tar.bz2 spark-c1ba4cd6b4db22a9325eee50dc40a78593a10de1.zip | |
[SPARK-3149] Connection establishment information is not enough.
Author: Kousuke Saruta <sarutak@oss.nttdata.co.jp>
Closes #2060 from sarutak/SPARK-3149 and squashes the following commits:
1cc89af [Kousuke Saruta] Modified log message of accepting connection
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/network/ConnectionManager.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala b/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala index b3e951ded6..e5e1e72cd9 100644 --- a/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala +++ b/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala @@ -418,7 +418,7 @@ private[spark] class ConnectionManager( newConnection.onReceive(receiveMessage) addListeners(newConnection) addConnection(newConnection) - logInfo("Accepted connection from [" + newConnection.remoteAddress.getAddress + "]") + logInfo("Accepted connection from [" + newConnection.remoteAddress + "]") } catch { // might happen in case of issues with registering with selector case e: Exception => logError("Error in accept loop", e) |