You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "Hyukjin Kwon (JIRA)" <ji...@apache.org> on 2019/05/21 04:00:04 UTC
[jira] [Updated] (SPARK-19772) Flaky test:
pyspark.streaming.tests.WindowFunctionTests
[ https://issues.apache.org/jira/browse/SPARK-19772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Hyukjin Kwon updated SPARK-19772:
---------------------------------
Labels: bulk-closed flaky-test (was: flaky-test)
> Flaky test: pyspark.streaming.tests.WindowFunctionTests
> -------------------------------------------------------
>
> Key: SPARK-19772
> URL: https://issues.apache.org/jira/browse/SPARK-19772
> Project: Spark
> Issue Type: Bug
> Components: DStreams, PySpark, Tests
> Affects Versions: 2.2.0
> Reporter: Kay Ousterhout
> Priority: Major
> Labels: bulk-closed, flaky-test
>
> 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
(v7.6.3#76005)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org