Fix CheckpointSuite test fail

2013-12-30 13:10:33 -08:00 · 2013-12-30 13:10:33 -08:00 · 347fafe4fc
parent d6e7910d92
commit 347fafe4fc
1 changed files with 2 additions and 2 deletions
--- 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() {