Re: Strange behavior of collectNeighbors API in GraphX

2016-03-13 Thread Zhaokang Wang
After further debugging into this issue, I find that this bug is related to the triplets view of a graph in GraphX. If a graph is generated by outer join two other graphs via outerJoinVertices operation, the graph's triplets view and the vertices view may be inconsistent. In the following

Strange behavior of collectNeighbors API in GraphX

2016-03-11 Thread Zhaokang Wang
comments on this? Thanks a lot. Regards, Zhaokang Wang PS. We have testedthe code on Spark 1.5.1 and 1.6.0. 鈥� The source code mentioned in the post: Main2.scala <http://apache-spark-user-list.1001560.n3.nabble.com/file/n26459/Main2.scala> -- View this message i

Strange behavior of collectNeighbors API in GraphX

2016-03-11 Thread Zhaokang Wang
hX or I call this API improperly or my vertex property is improper. Could you please give some comments on this? Thanks a lot. Regards, Zhaokang Wang PS. We have tested the code on Spark 1.5.1 and 1.6.0. ​ import org.apache.spark.{graphx, SparkConf, SparkContext} import org.apache.spark.graphx.Ed