aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorKay Ousterhout <kayousterhout@gmail.com>2014-03-03 14:39:49 -0800
committerReynold Xin <rxin@apache.org>2014-03-03 14:39:49 -0800
commit369aad6f9e25d49b0d32f37e5069b6d4e41a59d9 (patch)
treed1c0755046d1c3252a6b4677592670c24fe81d55 /core
parentf65c1f38eb7ed99a578a5430831a4a2c1d774e7a (diff)
downloadspark-369aad6f9e25d49b0d32f37e5069b6d4e41a59d9.tar.gz
spark-369aad6f9e25d49b0d32f37e5069b6d4e41a59d9.tar.bz2
spark-369aad6f9e25d49b0d32f37e5069b6d4e41a59d9.zip
Removed accidentally checked in comment
It looks like this comment was added a while ago by @mridulm as part of a merge and was accidentally checked in. We should remove it. Author: Kay Ousterhout <kayousterhout@gmail.com> Closes #61 from kayousterhout/remove_comment and squashes the following commits: 0b2b3f2 [Kay Ousterhout] Removed accidentally checked in comment
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/org/apache/spark/network/ConnectionManager.scala3
1 files changed, 0 insertions, 3 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 3dd82bee0b..a7f20f8c51 100644
--- a/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala
+++ b/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala
@@ -550,9 +550,6 @@ private[spark] class ConnectionManager(port: Int, conf: SparkConf) extends Loggi
newConnection
}
- // I removed the lookupKey stuff as part of merge ... should I re-add it ? We did not find it
- // useful in our test-env ... If we do re-add it, we should consistently use it everywhere I
- // guess ?
val connection = connectionsById.getOrElseUpdate(connectionManagerId, startNewConnection())
message.senderAddress = id.toSocketAddress()
logDebug("Sending [" + message + "] to [" + connectionManagerId + "]")