typo

marmbrus · Aug 19, 2014 · 11ba318 · 11ba318
1 parent 085aef8
commit 11ba318
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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,