Skip to content

Commit 2a1857a

Browse files
author
Davies Liu
committed
typo
1 parent d2f053b commit 2a1857a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

python/pyspark/shuffle.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -651,7 +651,7 @@ def next(self):
651651

652652
class ChainedIterable(object):
653653
"""
654-
Picklable chained iterator, similar to itertools.chain.fromiterable()
654+
Picklable chained iterator, similar to itertools.chain.from_iterable()
655655
"""
656656
def __init__(self, iterators):
657657
self.iterators = iterators
@@ -660,7 +660,7 @@ def __len__(self):
660660
return sum(len(vs) for vs in self.iterators)
661661

662662
def __iter__(self):
663-
return itertools.chain.fromiterable(self.iterators)
663+
return itertools.chain.from_iterable(self.iterators)
664664

665665

666666
class ExternalGroupBy(ExternalMerger):

0 commit comments

Comments
 (0)