diff options
| author | Andrew Or <andrewor14@gmail.com> | 2013-12-30 13:10:33 -0800 |
|---|---|---|
| committer | Andrew Or <andrewor14@gmail.com> | 2013-12-30 13:10:33 -0800 |
| commit | 347fafe4fccc9345ed0ffa6c7863bc233c079b43 (patch) | |
| tree | 29b04734da44ce9509eb98ff7a845f7bfa2a945c /core/src/main/scala/org | |
| parent | d6e7910d925039d9b57d82e7ca17e775c52fbee5 (diff) | |
| download | spark-347fafe4fccc9345ed0ffa6c7863bc233c079b43.tar.gz spark-347fafe4fccc9345ed0ffa6c7863bc233c079b43.tar.bz2 spark-347fafe4fccc9345ed0ffa6c7863bc233c079b43.zip | |
Fix CheckpointSuite test fail
Diffstat (limited to 'core/src/main/scala/org')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala | 4 |
1 files 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() { |