Robin Cheng created SPARK-10228: ----------------------------------- Summary: Integer overflow in VertexRDDImpl.count Key: SPARK-10228 URL: https://issues.apache.org/jira/browse/SPARK-10228 Project: Spark Issue Type: Bug Components: GraphX Affects Versions: 1.4.1 Reporter: Robin Cheng
VertexRDDImpl overrides RDD.count() but aggregates Int instead of Long: /** The number of vertices in the RDD. */ override def count(): Long = { partitionsRDD.map(_.size).reduce(_ + _) } This causes Pregel to stop iterating when the number of messages is "negative", giving incorrect results. -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org