diff --git a/python/pyspark/streaming/utils.py b/python/pyspark/streaming/utils.py
index 84f1dadeba03d..c60ecd1ed607a 100644
--- a/python/pyspark/streaming/utils.py
+++ b/python/pyspark/streaming/utils.py
@@ -17,6 +17,7 @@
 
 from pyspark.rdd import RDD
 
+
 class RDDFunction():
     def __init__(self, ctx, jrdd_deserializer, func):
         self.ctx = ctx