diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py index 77e8fb1773fd1..dc6497772e502 100644 --- 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):