Github user BryanCutler commented on a diff in the pull request: https://github.com/apache/spark/pull/20838#discussion_r211688118 --- Diff: python/pyspark/streaming/tests.py --- @@ -206,6 +207,38 @@ def func(dstream): expected = [[len(x)] for x in input] self._test_func(input, func, expected) + def test_slice(self): + """Basic operation test for DStream.slice.""" + import datetime as dt --- End diff -- lets remove the import here since it is at the top already
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org