aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorCharles Reiss <charles@eecs.berkeley.edu>2012-12-10 00:27:13 -0800
committerCharles Reiss <charles@eecs.berkeley.edu>2012-12-10 00:31:55 -0800
commitb6b62d774f23bec64b027ecdc3d6daba85830d78 (patch)
treeeab717f4327904558d2542343c4aa2f897654549 /core
parent5d3e917d09241c783a0e826caae9b85cf5b044bf (diff)
downloadspark-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.scala3
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
}
}