From 8f0819520c8ca8a2d33b6d07f77f07e2df994aa8 Mon Sep 17 00:00:00 2001
From: Charles Reiss <charles@eecs.berkeley.edu>
Date: Thu, 6 Dec 2012 18:29:50 -0800
Subject: [PATCH] map -> foreach
---
core/src/main/scala/spark/storage/BlockManagerMaster.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/scala/spark/storage/BlockManagerMaster.scala b/core/src/main/scala/spark/storage/BlockManagerMaster.scala
index 1a0b477d92..4ab73a6c0d 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
}
--
GitLab