You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/01/11 01:25:43 UTC
[26/50] git commit: Fix CheckpointSuite test fail
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 <an...@gmail.com>
Authored: Mon Dec 30 13:10:33 2013 -0800
Committer: Andrew Or <an...@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() {