From f7450a0095474db72b31458a37072a2ec40fa8a1 Mon Sep 17 00:00:00 2001
From: Justin Loew <jloloew@gmail.com>
Date: Sun, 15 Apr 2018 22:15:34 -0500
Subject: [PATCH] Moving changes, please ignore
---
.../main/scala/org/apache/spark/examples/SparkPageRank.scala | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
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 8a28597740..a9b1e6315c 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()
}
--
GitLab