From 6ae3caa089341521f98af5ac2a7be4126d3fda31 Mon Sep 17 00:00:00 2001 From: giwa Date: Wed, 20 Aug 2014 19:28:03 -0700 Subject: [PATCH] revert pom.xml --- python/pyspark/streaming/context.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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()