diff options
| author | Charles Reiss <charles@eecs.berkeley.edu> | 2012-12-06 18:29:50 -0800 |
|---|---|---|
| committer | Charles Reiss <charles@eecs.berkeley.edu> | 2012-12-06 18:29:50 -0800 |
| commit | 8f0819520c8ca8a2d33b6d07f77f07e2df994aa8 (patch) | |
| tree | 1557c61aedf5cff533557fd6a452d5ba830c2bb9 /core | |
| parent | 7a033fd795b2008b1cdaa0d0aab73817db56d708 (diff) | |
| download | spark-8f0819520c8ca8a2d33b6d07f77f07e2df994aa8.tar.gz spark-8f0819520c8ca8a2d33b6d07f77f07e2df994aa8.tar.bz2 spark-8f0819520c8ca8a2d33b6d07f77f07e2df994aa8.zip | |
map -> foreach
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/storage/BlockManagerMaster.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 } |