Fix Python test

Author: sryza

python/pyspark/rdd.py

@@ -1188,7 +1188,7 @@ def aggregateByKey(self, zeroValue, seqFunc, combFunc, numPartitions=None):
         for merging values between partitions. To avoid memory allocation, both of these functions are
         allowed to modify and return their first argument instead of creating a new U.
         """
-        return self.combineByKey(lambda v: func(zeroValue, v), seqFunc, combFunc, numPartitions)
+        return self.combineByKey(lambda v: seqFunc(zeroValue, v), seqFunc, combFunc, numPartitions)
 
     def foldByKey(self, zeroValue, func, numPartitions=None):
         """

python/pyspark/tests.py

@@ -198,7 +198,7 @@ def combOp(x, y):
             x |= y
             return x
 
-        sets = dict(pairs.aggregateByKey(set(), seqOp, combOp).collect())
+        sets = dict(data.aggregateByKey(set(), seqOp, combOp).collect())
         self.assertEqual(3, len(sets))
         self.assertEqual(set([1]), sets[1])
         self.assertEqual(set([2]), sets[3])