Skip to content
Snippets Groups Projects
Commit 58fc6b2b authored by Charles Reiss's avatar Charles Reiss
Browse files

Handle duplicate registrations better.

parent ad4232b4
No related branches found
No related tags found
No related merge requests found
......@@ -183,7 +183,7 @@ class BlockManagerMasterActor(val isLocal: Boolean) extends Actor with Logging {
if (blockManagerId.ip == Utils.localHostName() && !isLocal) {
logInfo("Got Register Msg from master node, don't register it")
} else {
} else if (!blockManagerInfo.contains(blockManagerId)) {
blockManagerIdByHost.get(blockManagerId.ip) match {
case Some(managers) =>
// A block manager of the same host name already exists.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment