From 30b8d369d459be5da133f12ebb33a9c74579f468 Mon Sep 17 00:00:00 2001 From: Sandy Ryza Date: Fri, 18 Jul 2014 00:47:43 -0700 Subject: SPARK-2553. Fix compile error Author: Sandy Ryza Closes #1479 from sryza/sandy-spark-2553 and squashes the following commits: 2cb5ed8 [Sandy Ryza] SPARK-2553. Fix compile error --- core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala | 1 + 1 file changed, 1 insertion(+) (limited to 'core/src') 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 b284b636f2..5366c1a1cc 100644 --- a/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala +++ b/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala @@ -185,6 +185,7 @@ class CoGroupedRDD[K](@transient var rdds: Seq[RDD[_ <: Product2[K, _]]], part: combiner1(depNum) ++= combiner2(depNum) depNum += 1 } + combiner1 } new ExternalAppendOnlyMap[K, CoGroupValue, CoGroupCombiner]( createCombiner, mergeValue, mergeCombiners) -- cgit v1.2.3