fix map function

YanTangZhai · Sep 20, 2014 · eb4bf48 · eb4bf48
1 parent 98c2a00
commit eb4bf48
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/python/pyspark/streaming/dstream.py b/python/pyspark/streaming/dstream.py
@@ -142,8 +142,8 @@ def combineLocally(iterator):
 
                 #TODO for count operation make sure count implementation
                 # This is different from what pyspark does
-                if isinstance(x, int):
-                    x = ("", x)
+                #if isinstance(x, int):
+                #    x = ("", x)
 
                 (k, v) = x
                 if k not in combiners: