PEP8 failed checks fixed

Author: dtolpin

python/pyspark/streaming/dstream.py

@@ -561,14 +561,13 @@ def invReduceFunc(t, a, b):
             if slideDuration is None:
                 slideDuration = self._slideDuration
             dstream = self._sc._jvm.PythonReducedWindowedDStream(reduced._jdstream.dstream(),
-                                                             jreduceFunc, jinvReduceFunc,
-                                                             self._ssc._jduration(windowDuration),
-                                                             self._ssc._jduration(slideDuration))
+                                                                 jreduceFunc, jinvReduceFunc,
+                                                                 self._ssc._jduration(windowDuration),
+                                                                 self._ssc._jduration(slideDuration))
             return DStream(dstream.asJavaDStream(), self._ssc, self._sc.serializer)
         else:
             return reduced.window(windowDuration, slideDuration).reduceByKey(func, numPartitions)
 
-
     def updateStateByKey(self, updateFunc, numPartitions=None):
         """
         Return a new "state" DStream where the state for each key is updated by applying