Skip to content

Commit dfdb3c9

Browse files
committed
minor fix
a copy of vertices with defaultVal is created before, and it's b in (a, b) => b see in VertexPartition.scala val fullIter = iter ++ routingTable.iterator.map(vid => (vid, defaultVal))
1 parent 1c70366 commit dfdb3c9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

graphx/src/main/scala/org/apache/spark/graphx/VertexRDD.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -392,7 +392,7 @@ object VertexRDD {
392392
*/
393393
def apply[VD: ClassTag](
394394
vertices: RDD[(VertexId, VD)], edges: EdgeRDD[_, _], defaultVal: VD): VertexRDD[VD] = {
395-
VertexRDD(vertices, edges, defaultVal, (a, b) => b)
395+
VertexRDD(vertices, edges, defaultVal, (a, b) => a)
396396
}
397397

398398
/**

0 commit comments

Comments
 (0)