We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent efa23df commit b40bae7Copy full SHA for b40bae7
python/pyspark/rdd.py
@@ -1627,7 +1627,7 @@ def groupByKey(it):
1627
BatchedSerializer(PickleSerializer(), 1024), 10)
1628
sorter = ExternalSorter(memory * 0.9, ser)
1629
it = sorter.sorted(it, key=operator.itemgetter(0))
1630
- return imap(lambda (k, v): ResultIterable(v), GroupByKey(it))
+ return imap(lambda (k, v): (k, ResultIterable(v)), GroupByKey(it))
1631
1632
else:
1633
# this is faster than sort based
0 commit comments