aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorjerryshao <saisai.shao@intel.com>2013-08-30 09:39:01 +0800
committerjerryshao <saisai.shao@intel.com>2013-08-30 09:39:01 +0800
commitf3dbe6b2158d6fdf1eef3841e9522b4236a3fa81 (patch)
tree3a30c0cfb2dbb2c0711cb33a8d823397718f476e /core
parentabdbacf2521ec40ee03ecc8e1aae8823013f24f1 (diff)
downloadspark-f3dbe6b2158d6fdf1eef3841e9522b4236a3fa81.tar.gz
spark-f3dbe6b2158d6fdf1eef3841e9522b4236a3fa81.tar.bz2
spark-f3dbe6b2158d6fdf1eef3841e9522b4236a3fa81.zip
Fix removed block zero size log reporting
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/spark/storage/BlockManagerMasterActor.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/storage/BlockManagerMasterActor.scala b/core/src/main/scala/spark/storage/BlockManagerMasterActor.scala
index 2a2e178550..b7a981d101 100644
--- a/core/src/main/scala/spark/storage/BlockManagerMasterActor.scala
+++ b/core/src/main/scala/spark/storage/BlockManagerMasterActor.scala
@@ -372,12 +372,12 @@ object BlockManagerMasterActor {
if (blockStatus.storageLevel.useMemory) {
_remainingMem += blockStatus.memSize
logInfo("Removed %s on %s in memory (size: %s, free: %s)".format(
- blockId, blockManagerId.hostPort, Utils.bytesToString(memSize),
+ blockId, blockManagerId.hostPort, Utils.bytesToString(blockStatus.memSize),
Utils.bytesToString(_remainingMem)))
}
if (blockStatus.storageLevel.useDisk) {
logInfo("Removed %s on %s on disk (size: %s)".format(
- blockId, blockManagerId.hostPort, Utils.bytesToString(diskSize)))
+ blockId, blockManagerId.hostPort, Utils.bytesToString(blockStatus.diskSize)))
}
}
}