diff --git a/python/pyspark/streaming/dstream.py b/python/pyspark/streaming/dstream.py
index fc15309679c2a..e1fc95db09eea 100644
--- a/python/pyspark/streaming/dstream.py
+++ b/python/pyspark/streaming/dstream.py
@@ -216,7 +216,7 @@ def getNumPartitions(self):
         """
         Return the number of partitions in RDD
         """
-        # TODO: remove hardcoding. RDD has NumPartitions. How do we get the number of partition
+        # TODO: remove hard coding. RDD has NumPartitions. How do we get the number of partition
         # through DStream?
         return 2
 
diff --git a/python/pyspark/streaming_tests.py b/python/pyspark/streaming/tests.py
similarity index 100%
rename from python/pyspark/streaming_tests.py
rename to python/pyspark/streaming/tests.py