diff --git a/python/pyspark/streaming/context.py b/python/pyspark/streaming/context.py
index 12023374333a2..6b6cc653dfa6f 100644
--- a/python/pyspark/streaming/context.py
+++ b/python/pyspark/streaming/context.py
@@ -147,7 +147,7 @@ def _testInputStream(self, test_inputs, numSlices=None):
             test_rdd = self._sc.parallelize(test_input, numSlices)
             test_rdds.append(test_rdd._jrdd)
             test_rdd_deserializers.append(test_rdd._jrdd_deserializer)
-        # All deserializer has to be the same.
+        # All deserializers have to be the same.
         # TODO: add deserializer validation
         jtest_rdds = ListConverter().convert(test_rdds, SparkContext._gateway._gateway_client)
         jinput_stream = self._jvm.PythonTestInputStream(self._jssc, jtest_rdds).asJavaDStream()