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 37af7596265d5c041e5c9d4e04232db1353a5d56..a80b98f4a7ef2c4715f7e694529adaef460a1b21 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 @@ -399,9 +399,13 @@ private[spark] class MemoryStore( val origEntry = entries.get(blockId) print("Hello, world!\n") logInfo(s"blockId: $blockId") + print("402\n") if (origEntry != null) { + print("404\n") blockIdAndSizeSet -= new OurBlockIdAndSizeType(blockId, origEntry.size) + print("406\n") } + print("408\n") entries.remove(blockId) } if (entry != null) {