diff --git a/core/src/main/scala/spark/storage/BlockManagerMaster.scala b/core/src/main/scala/spark/storage/BlockManagerMaster.scala index a5cdbae4da932b089d128efbe9847badf5ae4baa..a7b60fc2cffc2a7f293ba4b072b73ce659ba2cda 100644 --- a/core/src/main/scala/spark/storage/BlockManagerMaster.scala +++ b/core/src/main/scala/spark/storage/BlockManagerMaster.scala @@ -209,12 +209,13 @@ private[spark] class BlockManagerMasterActor(val isLocal: Boolean) extends Actor } def expireDeadHosts() { - logInfo("Checking for hosts with no recent heart beats in BlockManagerMaster.") + logDebug("Checking for hosts with no recent heart beats in BlockManagerMaster.") val now = System.currentTimeMillis() val minSeenTime = now - slaveTimeout val toRemove = new HashSet[BlockManagerId] for (info <- blockManagerInfo.values) { if (info.lastSeenMs < minSeenTime) { + logInfo("Removing BlockManager " + info.blockManagerId + " with no recent heart beats") toRemove += info.blockManagerId } }