diff options
author | Ankur Dave <ankurdave@gmail.com> | 2015-08-03 23:07:32 -0700 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2015-08-03 23:07:32 -0700 |
commit | 9e952ecbce670e9b532a1c664a4d03b66e404112 (patch) | |
tree | aa42f089fcc8da856f55a83b7cab29e0991f961b /graphx/src/main | |
parent | 0afa6fbf525723e97c6dacfdba3ad1762637ffa9 (diff) | |
download | spark-9e952ecbce670e9b532a1c664a4d03b66e404112.tar.gz spark-9e952ecbce670e9b532a1c664a4d03b66e404112.tar.bz2 spark-9e952ecbce670e9b532a1c664a4d03b66e404112.zip |
[SPARK-3190] [GRAPHX] Fix VertexRDD.count() overflow regression
SPARK-3190 was originally fixed by 96df92906978c5f58e0cc8ff5eebe5b35a08be3b, but a5ef58113667ff73562ce6db381cff96a0b354b0 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
Diffstat (limited to 'graphx/src/main')
-rw-r--r-- | graphx/src/main/scala/org/apache/spark/graphx/impl/VertexRDDImpl.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/impl/VertexRDDImpl.scala b/graphx/src/main/scala/org/apache/spark/graphx/impl/VertexRDDImpl.scala index 33ac7b0ed6..7f4e7e9d79 100644 --- a/graphx/src/main/scala/org/apache/spark/graphx/impl/VertexRDDImpl.scala +++ b/graphx/src/main/scala/org/apache/spark/graphx/impl/VertexRDDImpl.scala @@ -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]( |