diff options
author | Charles Reiss <charles@eecs.berkeley.edu> | 2012-12-10 00:27:13 -0800 |
---|---|---|
committer | Charles Reiss <charles@eecs.berkeley.edu> | 2012-12-10 00:31:55 -0800 |
commit | b6b62d774f23bec64b027ecdc3d6daba85830d78 (patch) | |
tree | eab717f4327904558d2542343c4aa2f897654549 /core | |
parent | 5d3e917d09241c783a0e826caae9b85cf5b044bf (diff) | |
download | spark-b6b62d774f23bec64b027ecdc3d6daba85830d78.tar.gz spark-b6b62d774f23bec64b027ecdc3d6daba85830d78.tar.bz2 spark-b6b62d774f23bec64b027ecdc3d6daba85830d78.zip |
Decrease BlockManagerMaster logging verbosity
Diffstat (limited to 'core')
-rw-r--r-- | core/src/main/scala/spark/storage/BlockManagerMaster.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/storage/BlockManagerMaster.scala b/core/src/main/scala/spark/storage/BlockManagerMaster.scala index a5cdbae4da..a7b60fc2cf 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 } } |