Skip to content
Snippets Groups Projects
Commit 9e952ecb authored by Ankur Dave's avatar Ankur Dave Committed by Reynold Xin
Browse files

[SPARK-3190] [GRAPHX] Fix VertexRDD.count() overflow regression

SPARK-3190 was originally fixed by 96df9290, but a5ef5811 introduced a regression during refactoring. This commit fixes the regression.

Author: Ankur Dave <ankurdave@gmail.com>

Closes #7923 from ankurdave/SPARK-3190-reopening and squashes the following commits:

a3e1b23 [Ankur Dave] Fix VertexRDD.count() overflow regression
parent 0afa6fbf
No related branches found
No related tags found
No related merge requests found
......@@ -87,7 +87,7 @@ class VertexRDDImpl[VD] private[graphx] (
/** The number of vertices in the RDD. */
override def count(): Long = {
partitionsRDD.map(_.size).reduce(_ + _)
partitionsRDD.map(_.size.toLong).reduce(_ + _)
}
override private[graphx] def mapVertexPartitions[VD2: ClassTag](
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment