merge with master

YanTangZhai · Sep 20, 2014 · 58e41ff · 58e41ff
1 parent 455e5af
commit 58e41ff
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/python/pyspark/streaming/dstream.py b/python/pyspark/streaming/dstream.py
@@ -436,6 +436,7 @@ def __init__(self, prev, func, preservesPartitioning=False):
             self._prev_jrdd_deserializer = prev._jrdd_deserializer
         else:
             prev_func = prev.func
+
             def pipeline_func(split, iterator):
                 return func(split, prev_func(split, iterator))
             self.func = pipeline_func