Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Removed accidentally checked in comment
  • Loading branch information
kayousterhout committed Mar 3, 2014
commit 0b2b3f2c759d51950f5a9dd323e35818258d26fc
Original file line number Diff line number Diff line change
Expand Up @@ -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 + "]")
Expand Down