diff options
| -rw-r--r-- | graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala b/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala index aeae378051..d15423e611 100644 --- a/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala +++ b/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala @@ -217,7 +217,8 @@ class GraphImpl[VD: ClassManifest, ED: ClassManifest] protected ( // Map and combine. val preAgg = edges.zipEdgePartitions(vs) { (edgePartition, vTableReplicatedIter) => - val (pid, vertexPartition) = vTableReplicatedIter.next() + val (_, vertexPartition) = vTableReplicatedIter.next() + // Iterate over the partition val et = new EdgeTriplet[VD, ED] val filteredEdges = edgePartition.iterator.flatMap { e => |