Unpersist edges of previous graph in Pregel

ankurdave · ankurdave · commit 13d5b07eb489 · 2014-06-04T18:25:42.000-07:00
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
     }

Original file line number	Diff line number	Diff line change
`@@ -150,6 +150,7 @@ object Pregel extends Logging {`
`150`	`150`	`oldMessages.unpersist(blocking=false)`
`151`	`151`	`newVerts.unpersist(blocking=false)`
`152`	`152`	`prevG.unpersistVertices(blocking=false)`
	`153`	`+ prevG.edges.unpersist(blocking=false)`
`153`	`154`	`// count the iteration`
`154`	`155`	`i += 1`
`155`	`156`	`}`