SPARK-2553. Fix compile error

sryza · rxin · commit 30b8d369d459 · 2014-07-18T00:47:43.000-07:00
Author: Sandy Ryza <sandy@cloudera.com> Closes #1479 from sryza/sandy-spark-2553 and squashes the following commits: 2cb5ed8 [Sandy Ryza] SPARK-2553. Fix compile error
diff --git 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)

Original file line number	Diff line number	Diff line change
`@@ -185,6 +185,7 @@ class CoGroupedRDD[K](@transient var rdds: Seq[RDD[_ <: Product2[K, _]]], part:`
`185`	`185`	`combiner1(depNum) ++= combiner2(depNum)`
`186`	`186`	`depNum += 1`
`187`	`187`	`}`
	`188`	`+ combiner1`
`188`	`189`	`}`
`189`	`190`	`new ExternalAppendOnlyMap[K, CoGroupValue, CoGroupCombiner](`
`190`	`191`	`createCombiner, mergeValue, mergeCombiners)`