We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3ae0cda commit 2d4f6e7Copy full SHA for 2d4f6e7
graphx/src/main/scala/org/apache/spark/graphx/VertexRDD.scala
@@ -68,7 +68,7 @@ abstract class VertexRDD[VD](
68
* Provides the `RDD[(VertexId, VD)]` equivalent output.
69
*/
70
override def compute(part: Partition, context: TaskContext): Iterator[(VertexId, VD)] = {
71
- firstParent[ShippableVertexPartition[VD]].iterator(part, context).next.iterator
+ firstParent[ShippableVertexPartition[VD]].iterator(part, context).next().iterator
72
}
73
74
/**
0 commit comments