Kay Ousterhout created SPARK-19772:
--------------------------------------
Summary: 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: [email protected]
For additional commands, e-mail: [email protected]
