From b57ecec530eb7c092a511c33d9528c58a2913311 Mon Sep 17 00:00:00 2001
From: Justin Loew <jloloew@gmail.com>
Date: Sat, 5 May 2018 15:02:08 -0500
Subject: [PATCH] Add print statements to debug MemoryStore
---
.../scala/org/apache/spark/storage/memory/MemoryStore.scala | 4 ++++
1 file changed, 4 insertions(+)
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 37af759626..a80b98f4a7 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) {
--
GitLab