diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala
index 3c9fff6f4bf5c..717592dbf8bf9 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala
@@ -198,4 +198,4 @@ class PythonTestInputStream(ssc_ : JavaStreamingContext, inputRDDs: JArrayList[J
   }
 
   val asJavaDStream  = JavaDStream.fromDStream(this)
-}
+}
\ No newline at end of file
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonRDDFunction.java b/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonRDDFunction.java
index 84d092ea0048f..eacff4b0e6006 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonRDDFunction.java
+++ b/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonRDDFunction.java
@@ -9,4 +9,4 @@
  */
 public interface PythonRDDFunction {
   JavaRDD<byte[]> call(JavaRDD<byte[]> rdd, long time);
-}
+}
\ No newline at end of file