diff options
| -rw-r--r-- | core/src/main/scala/spark/storage/BlockManager.scala | 3 |
1 files changed, 2 insertions, 1 deletions
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 |