Skip to content

Commit adc5fc3

Browse files
author
Yves Raimond
committed
Undoing destroy
1 parent 7dc2c23 commit adc5fc3

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

graphx/src/main/scala/org/apache/spark/graphx/lib/PageRank.scala

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -232,16 +232,15 @@ object PageRank extends Logging {
232232
rankGraph.edges.foreachPartition(x => {}) // also materializes rankGraph.vertices
233233
prevRankGraph.vertices.unpersist(false)
234234
prevRankGraph.edges.unpersist(false)
235-
sourcesInitMapBC.destroy(false)
236235

237236
logInfo(s"Parallel Personalized PageRank finished iteration $i.")
238237

239238
i += 1
240239
}
241240

242241
rankGraph.mapVertices { (vid, attr) =>
243-
Vectors.fromBreeze(attr)
244-
}
242+
Vectors.fromBreeze(attr)
243+
}
245244
}
246245

247246
/**

0 commit comments

Comments
 (0)