diff options
| author | Kousuke Saruta <sarutak@oss.nttdata.co.jp> | 2014-08-19 10:15:11 -0700 |
|---|---|---|
| committer | Josh Rosen <joshrosen@apache.org> | 2014-08-19 10:15:11 -0700 |
| commit | cbfc26ba45f49559e64276c72e3054c6fe30ddd5 (patch) | |
| tree | 7b6cea6df84e239ca96dd443e80a53515eb167fc /core | |
| parent | 7eb9cbc273d758522e787fcb2ef68ef65911475f (diff) | |
| download | spark-cbfc26ba45f49559e64276c72e3054c6fe30ddd5.tar.gz spark-cbfc26ba45f49559e64276c72e3054c6fe30ddd5.tar.bz2 spark-cbfc26ba45f49559e64276c72e3054c6fe30ddd5.zip | |
[SPARK-3089] Fix meaningless error message in ConnectionManager
Author: Kousuke Saruta <sarutak@oss.nttdata.co.jp>
Closes #2000 from sarutak/SPARK-3089 and squashes the following commits:
02dfdea [Kousuke Saruta] Merge branch 'master' of git://git.apache.org/spark into SPARK-3089
e759ce7 [Kousuke Saruta] Improved error message when closing SendingConnection
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 e77d762bdf..b3e951ded6 100644 --- a/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala +++ b/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala @@ -467,7 +467,7 @@ private[spark] class ConnectionManager( val sendingConnectionOpt = connectionsById.get(remoteConnectionManagerId) if (!sendingConnectionOpt.isDefined) { - logError("Corresponding SendingConnectionManagerId not found") + logError(s"Corresponding SendingConnection to ${remoteConnectionManagerId} not found") return } |