Skip to content

Commit e746aec

Browse files
author
Davies Liu
committed
fix batch size during sort
1 parent 49f19b9 commit e746aec

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

python/pyspark/shuffle.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -512,9 +512,6 @@ def load(f):
512512
f.close()
513513
chunks.append(load(open(path, 'rb')))
514514
current_chunk = []
515-
gc.collect()
516-
batch //= 2
517-
limit = self._next_limit()
518515
MemoryBytesSpilled += max(used_memory - get_used_memory(), 0) << 20
519516
DiskBytesSpilled += os.path.getsize(path)
520517
os.unlink(path) # data will be deleted after close

0 commit comments

Comments
 (0)