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

Decrease BlockManagerMaster logging verbosity

parent 5d3e917d
No related branches found
No related tags found
No related merge requests found
......@@ -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
}
}
......
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