diff options
| author | Ankur Dave <ankurdave@gmail.com> | 2013-12-13 01:56:07 -0800 |
|---|---|---|
| committer | Ankur Dave <ankurdave@gmail.com> | 2013-12-14 15:28:22 -0800 |
| commit | d076fe5c9ef3d83af0fb737608660992cb730a7c (patch) | |
| tree | 0142a03581dcfec12b582ac6ae06d7f81001b98f /graph/src | |
| parent | 4f4f0add2496c5478b0538c0dc861dba4419459c (diff) | |
| download | spark-d076fe5c9ef3d83af0fb737608660992cb730a7c.tar.gz spark-d076fe5c9ef3d83af0fb737608660992cb730a7c.tar.bz2 spark-d076fe5c9ef3d83af0fb737608660992cb730a7c.zip | |
Finish up 49f7fc5ed2edd42b118182438d84ed7d4e7d521f
Diffstat (limited to 'graph/src')
| -rw-r--r-- | graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala | 2 |
1 files changed, 1 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 e14718e67d..dd058f42c0 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 @@ -223,7 +223,7 @@ class GraphImpl[VD: ClassManifest, ED: ClassManifest] protected ( val (_, vertexPartition) = vTableReplicatedIter.next() // Iterate over the partition - val et = new EdgeTriplet[VD, ED](vertexPartition) + val et = new EdgeTriplet[VD, ED] val filteredEdges = edgePartition.iterator.flatMap { e => // Ensure that the edge meets the requirements of skipStaleSrc and skipStaleDst val srcVertexOK = !skipStaleSrc || vertexPartition.isDefined(e.srcId) |