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 e3556b72ad23ef23bc86a36aa6f27d020ec1b807..7c2bb8d6fa27375f796d14768f0b697c56388726 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 @@ -406,7 +406,7 @@ private[spark] class MemoryStore( case _ => } memoryManager.releaseStorageMemory(entry.size, entry.memoryMode) - logDebug(s"Block $blockId of size ${entry.size} dropped " + + logInfo(s"Block $blockId of size ${entry.size} dropped " + s"from memory (free ${maxMemory - blocksMemoryUsed})") true } else { diff --git a/examples/src/main/scala/org/apache/spark/examples/SparkPageRank.scala b/examples/src/main/scala/org/apache/spark/examples/SparkPageRank.scala index 9299bad5d3290d74f39605375d9831065130f453..75c759a40572159bb43a5ad2e015f1dc4e05d281 100644 --- a/examples/src/main/scala/org/apache/spark/examples/SparkPageRank.scala +++ b/examples/src/main/scala/org/apache/spark/examples/SparkPageRank.scala @@ -18,6 +18,7 @@ // scalastyle:off println package org.apache.spark.examples +import org.apache.spark.memory.MemoryMode import org.apache.spark.sql.SparkSession /** @@ -79,6 +80,9 @@ object SparkPageRank { val output = ranks.collect() output.foreach(tup => println(s"${tup._1} has rank: ${tup._2} .")) + spark.sparkContext.env.blockManager.memoryStore + .evictBlocksToFreeSpace(None, 1000000L, MemoryMode.ON_HEAP) + spark.stop() } }