Fixing bug in VertexSetRDD that breaks Graph tests.

2013-10-18 23:44:06 -07:00 · 2013-10-18 23:44:06 -07:00 · dbc8c9868a
parent 9cf43cfeb7
commit dbc8c9868a
1 changed files with 1 additions and 1 deletions
--- 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)