From dbc8c9868aac33faa45ab54935df3613e31d4ff9 Mon Sep 17 00:00:00 2001
From: "Joseph E. Gonzalez" <joseph.e.gonzalez@gmail.com>
Date: Fri, 18 Oct 2013 23:44:06 -0700
Subject: [PATCH] Fixing bug in VertexSetRDD that breaks Graph tests.
---
graph/src/main/scala/org/apache/spark/graph/VertexSetRDD.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/graph/src/main/scala/org/apache/spark/graph/VertexSetRDD.scala b/graph/src/main/scala/org/apache/spark/graph/VertexSetRDD.scala
index b3f1fa768c..e92c4e1fb1 100644
--- a/graph/src/main/scala/org/apache/spark/graph/VertexSetRDD.scala
+++ b/graph/src/main/scala/org/apache/spark/graph/VertexSetRDD.scala
@@ -219,7 +219,7 @@ class VertexSetRDD[V: ClassManifest](
if (other.partitioner == Some(partitioner)) other
else other.partitionBy(partitioner)
val newValues: RDD[ (IndexedSeq[(V,Option[W])], BitSet) ] =
- index.rdd.zipPartitions(valuesRDD, other) {
+ index.rdd.zipPartitions(valuesRDD, otherShuffled) {
(thisIndexIter, thisIter, tuplesIter) =>
val index = thisIndexIter.next()
assert(!thisIndexIter.hasNext)
--
GitLab