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 8a28597740d81de6b61f87e9cff5931ac0096a87..a9b1e6315c5ce738cf837449e5259427b5564a0f 100644 --- a/examples/src/main/scala/org/apache/spark/examples/SparkPageRank.scala +++ b/examples/src/main/scala/org/apache/spark/examples/SparkPageRank.scala @@ -18,8 +18,8 @@ // scalastyle:off println package org.apache.spark.examples -import org.apache.spark.sql.SparkSession import org.apache.spark.memory +import org.apache.spark.sql.SparkSession /** * Computes the PageRank of URLs from an input file. Input file should @@ -80,7 +80,8 @@ object SparkPageRank { val output = ranks.collect() output.foreach(tup => println(s"${tup._1} has rank: ${tup._2} .")) - spark.sparkContext.env.blockManager.memoryStore.evictBlocksToFreeSpace(none, 100000000L, MemoryMode.ON_HEAP) + spark.sparkContext.env.blockManager.memoryStore + .evictBlocksToFreeSpace(None, 100000000L, MemoryMode.ON_HEAP) spark.stop() }