ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Revert "Fix join error by caching vTable in mapReduceTriplets"

Browse source 
This reverts commit dee1318d3d, which is
unnecessary due to 7528e6d5f1.
This commit is contained in:
Ankur Dave 2013-11-30 14:05:32 -08:00
parent e72bd91590
commit 3292cb0f9c
1 changed files with 0 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala
View file

@ -258,9 +258,6 @@ class GraphImpl[VD: ClassManifest, ED: ClassManifest] protected (
} }
} }
// Permit joining the result of mapReduceTriplets back with vTable
vTable.cache()
// do the final reduction reusing the index map // do the final reduction reusing the index map
vTable.aggregateUsingIndex(preAgg, reduceFunc) vTable.aggregateUsingIndex(preAgg, reduceFunc)
} // end of mapReduceTriplets } // end of mapReduceTriplets