From 58e41ff4588a1c0d31b83d43ec3155de7fb92a02 Mon Sep 17 00:00:00 2001
From: giwa <ugw.gi.world@gmail.com>
Date: Mon, 18 Aug 2014 16:55:51 -0700
Subject: [PATCH] merge with master

---
 python/pyspark/streaming/dstream.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/python/pyspark/streaming/dstream.py b/python/pyspark/streaming/dstream.py
index 66024d539ce5c..a36f4b9bf9d87 100644
--- 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