Skip to content

Commit 9d1de23

Browse files
committed
revert pom.xml
1 parent 7339df2 commit 9d1de23

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

python/pyspark/streaming/context.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,7 @@ def _testInputStream(self, test_inputs, numSlices=None):
147147
test_rdd = self._sc.parallelize(test_input, numSlices)
148148
test_rdds.append(test_rdd._jrdd)
149149
test_rdd_deserializers.append(test_rdd._jrdd_deserializer)
150-
# All deserializer has to be the same.
150+
# All deserializers have to be the same.
151151
# TODO: add deserializer validation
152152
jtest_rdds = ListConverter().convert(test_rdds, SparkContext._gateway._gateway_client)
153153
jinput_stream = self._jvm.PythonTestInputStream(self._jssc, jtest_rdds).asJavaDStream()

0 commit comments

Comments
 (0)