Skip to content

Commit 52c535b

Browse files
committed
remove fix for sum()
1 parent e108ec1 commit 52c535b

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

python/pyspark/rdd.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -787,8 +787,6 @@ def sum(self):
787787
>>> sc.parallelize([1.0, 2.0, 3.0]).sum()
788788
6.0
789789
"""
790-
if not self.getNumPartitions():
791-
return 0 # empty RDD can not been reduced
792790
return self.mapPartitions(lambda x: [sum(x)]).reduce(operator.add)
793791

794792
def count(self):

0 commit comments

Comments
 (0)