From 347fafe4fccc9345ed0ffa6c7863bc233c079b43 Mon Sep 17 00:00:00 2001 From: Andrew Or Date: Mon, 30 Dec 2013 13:10:33 -0800 Subject: Fix CheckpointSuite test fail --- core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 9066215866..77a594a3e4 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() { -- cgit v1.2.3