remove fix for sum()

YanTangZhai · Oct 3, 2014 · 52c535b · 52c535b
1 parent e108ec1
commit 52c535b
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py
@@ -787,8 +787,6 @@ def sum(self):
         >>> sc.parallelize([1.0, 2.0, 3.0]).sum()
         6.0
         """
-        if not self.getNumPartitions():
-            return 0  # empty RDD can not been reduced
         return self.mapPartitions(lambda x: [sum(x)]).reduce(operator.add)
 
     def count(self):