Unpersist edges of previous graph in Pregel

xiliu82 · Jun 5, 2014 · 13d5b07 · 13d5b07
1 parent abea2d4
commit 13d5b07
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/Pregel.scala b/graphx/src/main/scala/org/apache/spark/graphx/Pregel.scala
@@ -150,6 +150,7 @@ object Pregel extends Logging {
       oldMessages.unpersist(blocking=false)
       newVerts.unpersist(blocking=false)
       prevG.unpersistVertices(blocking=false)
+      prevG.edges.unpersist(blocking=false)
       // count the iteration
       i += 1
     }