diff --git a/core/src/main/scala/spark/storage/BlockManagerMaster.scala b/core/src/main/scala/spark/storage/BlockManagerMaster.scala index 1a0b477d921729ef931be930151d47ec6704682e..4ab73a6c0d029c63ae3c8fecbd5d297e65e361ba 100644 --- a/core/src/main/scala/spark/storage/BlockManagerMaster.scala +++ b/core/src/main/scala/spark/storage/BlockManagerMaster.scala @@ -225,7 +225,7 @@ private[spark] class BlockManagerMasterActor(val isLocal: Boolean) extends Actor def removeHost(host: String) { logInfo("Trying to remove the host: " + host + " from BlockManagerMaster.") logInfo("Previous hosts: " + blockManagerInfo.keySet.toSeq) - blockManagerIdByHost.get(host).map(removeBlockManager) + blockManagerIdByHost.get(host).foreach(removeBlockManager) logInfo("Current hosts: " + blockManagerInfo.keySet.toSeq) sender ! true }