revert pom.xml

YanTangZhai · Sep 20, 2014 · 6ae3caa · 6ae3caa
1 parent 7dc7391
commit 6ae3caa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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()