Destroying broadcast map

apache · Sep 9, 2016 · 40f5780 · 40f5780
1 parent 4b2d564
commit 40f5780
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/lib/PageRank.scala b/graphx/src/main/scala/org/apache/spark/graphx/lib/PageRank.scala
@@ -232,6 +232,7 @@ object PageRank extends Logging {
       rankGraph.edges.foreachPartition(x => {}) // also materializes rankGraph.vertices
       prevRankGraph.vertices.unpersist(false)
       prevRankGraph.edges.unpersist(false)
+      sourcesInitMapBC.destroy(false)
 
       logInfo(s"Parallel Personalized PageRank finished iteration $i.")