Hi I am facing a similar issue. It's not that the message is getting lost or something. The vertex 1 attributes changes in super step 1 but when the sendMsg gets the vertex attribute from the edge triplet in the 2nd superstep it stills has the old value of vertex 1 and not the latest value. So as per your code no new msg will be generated in the superstep. I think the bug is in the replicatedVertexView where the srcAttr and dstAttr of the edgeTripplet is updated from the latest version of the vertex after each superstep.
How to get this bug raised? I am struggling to find an exact solution for it except for recreating the graph after every superstep to reinforce edge triplets to have the latest value of the vertex. but this is not a good solution performance wise. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/GraphX-Pregel-not-update-vertex-state-properly-cause-messages-loss-tp28100p28123.html Sent from the Apache Spark User List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe e-mail: user-unsubscr...@spark.apache.org
