Skip to content

Commit 8d43a5f

Browse files
committed
Revert "Merge pull request apache#57 from Shopify/do_not_shrink_shuffle_batch_size"
This reverts commit 044b478, reversing changes made to b68a83b.
1 parent 0bc709d commit 8d43a5f

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

python/pyspark/shuffle.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -513,6 +513,7 @@ def load(f):
513513
chunks.append(load(open(path, 'rb')))
514514
current_chunk = []
515515
gc.collect()
516+
batch //= 2
516517
limit = self._next_limit()
517518
MemoryBytesSpilled += max(used_memory - get_used_memory(), 0) << 20
518519
DiskBytesSpilled += os.path.getsize(path)

0 commit comments

Comments
 (0)