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 a80b98f4a7ef2c4715f7e694529adaef460a1b21..f6a3b9bd2ef4c97203d48b9034566740921883af 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 @@ -409,15 +409,19 @@ private[spark] class MemoryStore( entries.remove(blockId) } if (entry != null) { + print("412\n") entry match { - case SerializedMemoryEntry(buffer, _, _) => buffer.dispose() - case _ => + case SerializedMemoryEntry(buffer, _, _) => print("414\n"); buffer.dispose() + case _ => print("415\n") } + print("417\n") memoryManager.releaseStorageMemory(entry.size, entry.memoryMode) + print("419\n") logInfo(s"Block $blockId of size ${entry.size} dropped " + s"from memory (free ${maxMemory - blocksMemoryUsed})") true } else { + print("424\n") false } }