From 0bc63f7ef1a22ce92b21ea9fe417df43923c1ce7 Mon Sep 17 00:00:00 2001 From: root Date: Sun, 7 Oct 2012 03:51:04 +0000 Subject: Log initial number of fetches in reducer --- core/src/main/scala/spark/storage/BlockManager.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'core/src/main') diff --git a/core/src/main/scala/spark/storage/BlockManager.scala b/core/src/main/scala/spark/storage/BlockManager.scala index c9bcd26016..c1d1e35ace 100644 --- a/core/src/main/scala/spark/storage/BlockManager.scala +++ b/core/src/main/scala/spark/storage/BlockManager.scala @@ -459,7 +459,8 @@ class BlockManager(val master: BlockManagerMaster, val serializer: Serializer, m sendRequest(fetchRequests.dequeue()) } - logDebug("Started remote gets in " + Utils.getUsedTimeMs(startTime) + " ms") + val numGets = remoteBlockIds.size - fetchRequests.size + logInfo("Started " + numGets + " remote gets in " + Utils.getUsedTimeMs(startTime)) // Get the local blocks while remote blocks are being fetched. Note that it's okay to do // these all at once because they will just memory-map some files, so they won't consume -- cgit v1.2.3