Skip to content
Snippets Groups Projects
Commit 077ae0a1 authored by Matei Zaharia's avatar Matei Zaharia
Browse files

Merge pull request #561 from ash211/patch-4

Add details when BlockManager heartbeats time out
parents e2aa8755 29d3440e
No related branches found
No related tags found
No related merge requests found
......@@ -121,7 +121,8 @@ class BlockManagerMasterActor(val isLocal: Boolean) extends Actor with Logging {
val toRemove = new HashSet[BlockManagerId]
for (info <- blockManagerInfo.values) {
if (info.lastSeenMs < minSeenTime) {
logWarning("Removing BlockManager " + info.blockManagerId + " with no recent heart beats")
logWarning("Removing BlockManager " + info.blockManagerId + " with no recent heart beats: "
(now - info.lastSeenMs) + "ms exceeds " + slaveTimeout + "ms")
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