[ https://issues.apache.org/jira/browse/SPARK-19772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15888758#comment-15888758 ]
Kay Ousterhout commented on SPARK-19772: ---------------------------------------- [~mengxr][~davies] It looks like this came up a while ago in SPARK-7497 and you fixed it. Any chance you could look at this again? > Flaky test: pyspark.streaming.tests.WindowFunctionTests > ------------------------------------------------------- > > Key: SPARK-19772 > URL: https://issues.apache.org/jira/browse/SPARK-19772 > Project: Spark > Issue Type: Bug > Components: PySpark, Structured Streaming, Tests > Affects Versions: 2.2.0 > Reporter: Kay Ousterhout > > Here's the link to the failed build: > https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/73598 > FAIL [16.440s]: test_count_by_value_and_window > (pyspark.streaming.tests.WindowFunctionTests) > ---------------------------------------------------------------------- > Traceback (most recent call last): > File > "/home/jenkins/workspace/SparkPullRequestBuilder/python/pyspark/streaming/tests.py", > line 668, in test_count_by_value_and_window > self._test_func(input, func, expected) > File > "/home/jenkins/workspace/SparkPullRequestBuilder/python/pyspark/streaming/tests.py", > line 162, in _test_func > self.assertEqual(expected, result) > AssertionError: Lists differ: [[(0,[312 chars] 2), (5, 1)], [(0, 1), (1, 1), > (2, 1), (3, 1), (4, 1), (5, 1)]] != [[(0,[312 chars] 2), (5, 1)]] > First list contains 1 additional elements. > First extra element 9: > [(0, 1), (1, 1), (2, 1), (3, 1), (4, 1), (5, 1)] > [[(0, 1)], > [(0, 2), (1, 1)], > [(0, 3), (1, 2), (2, 1)], > [(0, 4), (1, 3), (2, 2), (3, 1)], > [(0, 5), (1, 4), (2, 3), (3, 2), (4, 1)], > [(0, 5), (1, 5), (2, 4), (3, 3), (4, 2), (5, 1)], > [(0, 4), (1, 4), (2, 4), (3, 3), (4, 2), (5, 1)], > [(0, 3), (1, 3), (2, 3), (3, 3), (4, 2), (5, 1)], > - [(0, 2), (1, 2), (2, 2), (3, 2), (4, 2), (5, 1)], > ? ^ > + [(0, 2), (1, 2), (2, 2), (3, 2), (4, 2), (5, 1)]] > ? ^ > - [(0, 1), (1, 1), (2, 1), (3, 1), (4, 1), (5, 1)]] > Stdout: > ('timeout after', 15) -- This message was sent by Atlassian JIRA (v6.3.15#6346) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org