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 c68f8c2130..b445c8ad2b 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 @@ -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 vTable.aggregateUsingIndex(preAgg, reduceFunc) } // end of mapReduceTriplets