From 11ba318a39cda531894f85b318415d74dfd1b082 Mon Sep 17 00:00:00 2001 From: Davies Liu Date: Tue, 19 Aug 2014 00:26:16 -0700 Subject: [PATCH] typo --- python/pyspark/shuffle.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python/pyspark/shuffle.py b/python/pyspark/shuffle.py index 5399dc1c350bb..642e95beceb37 100644 --- a/python/pyspark/shuffle.py +++ b/python/pyspark/shuffle.py @@ -602,7 +602,7 @@ def _spill(self): self.spills += 1 gc.collect() # release the memory as much as possible - def _merge_items(self, index, limit=0): + def _merged_items(self, index, limit=0): size = sum(os.path.getsize(os.path.join(self._get_spill_dir(j), str(index))) for j in range(self.spills)) # if the memory can not hold all the partition,