ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Fixing a bug in pregel where the initial vertex-program results are lost.

Browse source
This commit is contained in:
Joseph E. Gonzalez 2013-10-22 19:10:51 -07:00
parent be8269af07
commit 0bd92ed8d0
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
graph/src/main/scala/org/apache/spark/graph/Pregel.scala
View file

@ -50,7 +50,7 @@ object Pregel {
def mapF(vid: Vid, edge: EdgeTriplet[VD,ED]) = sendMsg(edge.otherVertexId(vid), edge)
// Receive the first set of messages
g.mapVertices( (vid, vdata) => vprog(vid, vdata, initialMsg))
g = g.mapVertices( (vid, vdata) => vprog(vid, vdata, initialMsg))
while (i < numIter) {
// compute the messages