From a5195404110a6f69c8ec7f68bf5df56c6cd95cab Mon Sep 17 00:00:00 2001 From: jerryshao Date: Mon, 4 Jul 2016 14:22:46 +0800 Subject: [PATCH] [Minor][Core] Fix display wrong free memory size in the log --- core/src/main/scala/org/apache/spark/storage/MemoryStore.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/storage/MemoryStore.scala b/core/src/main/scala/org/apache/spark/storage/MemoryStore.scala index 17aae6e1bbdd..aed0da96d34c 100644 --- a/core/src/main/scala/org/apache/spark/storage/MemoryStore.scala +++ b/core/src/main/scala/org/apache/spark/storage/MemoryStore.scala @@ -393,7 +393,8 @@ private[spark] class MemoryStore(blockManager: BlockManager, memoryManager: Memo } val valuesOrBytes = if (deserialized) "values" else "bytes" logInfo("Block %s stored as %s in memory (estimated size %s, free %s)".format( - blockId, valuesOrBytes, Utils.bytesToString(size), Utils.bytesToString(blocksMemoryUsed))) + blockId, valuesOrBytes, Utils.bytesToString(size), + Utils.bytesToString(maxMemory - blocksMemoryUsed))) } else { // Tell the block manager that we couldn't put it in memory so that it can drop it to // disk if the block allows disk storage.