diff --git a/core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala b/core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala index f991380ecebc09ddb454f2abddcd44946fa8d4f5..a97bd6c51b20e7e4a7acdcf14ec1a87b21f2def6 100644 --- a/core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala +++ b/core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala @@ -397,6 +397,7 @@ private[spark] class MemoryStore( def remove(blockId: BlockId): Boolean = memoryManager.synchronized { val entry = entries.synchronized { val origEntry = entries.get(blockId) + logInfo(s"blockId: $blockId"); if (origEntry != null) { blockIdAndSizeSet -= new OurBlockIdAndSizeType(blockId, origEntry.size) }