spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pwend...@apache.org
Subject [26/50] git commit: Fix CheckpointSuite test fail
Date Sat, 11 Jan 2014 00:25:43 GMT
Fix CheckpointSuite test fail


Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/347fafe4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/347fafe4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/347fafe4

Branch: refs/heads/master
Commit: 347fafe4fccc9345ed0ffa6c7863bc233c079b43
Parents: d6e7910
Author: Andrew Or <andrewor14@gmail.com>
Authored: Mon Dec 30 13:10:33 2013 -0800
Committer: Andrew Or <andrewor14@gmail.com>
Committed: Mon Dec 30 13:10:33 2013 -0800

----------------------------------------------------------------------
 core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/347fafe4/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala b/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala
index 9066215..77a594a 100644
--- a/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala
+++ b/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala
@@ -173,8 +173,8 @@ class CoGroupedRDD[K](@transient var rdds: Seq[RDD[_ <: Product2[K,
_]]], part:
         case (v1, v2) => v1 ++ v2
       }
     }
-    new ExternalAppendOnlyMap[K, CoGroupValue, CoGroupCombiner](createCombiner, mergeValue,
-      mergeCombiners, SparkEnv.get.serializerManager.get(serializerClass))
+    new ExternalAppendOnlyMap[K, CoGroupValue, CoGroupCombiner](
+      createCombiner, mergeValue, mergeCombiners)
   }
 
   override def clearDependencies() {


Mime
View raw message