bugfix

rekhajoshm · Aug 16, 2014 · b40bae7 · b40bae7
1 parent efa23df
commit b40bae7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py
@@ -1627,7 +1627,7 @@ def groupByKey(it):
                     BatchedSerializer(PickleSerializer(), 1024), 10)
                 sorter = ExternalSorter(memory * 0.9, ser)
                 it = sorter.sorted(it, key=operator.itemgetter(0))
-                return imap(lambda (k, v): ResultIterable(v), GroupByKey(it))
+                return imap(lambda (k, v): (k, ResultIterable(v)), GroupByKey(it))
 
             else:
                 # this is faster than sort based