You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Kenneth Knowles (Jira)" <ji...@apache.org> on 2021/03/15 21:46:00 UTC
[jira] [Updated] (BEAM-11314) StreamingWordCountIT is flaky
[ https://issues.apache.org/jira/browse/BEAM-11314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kenneth Knowles updated BEAM-11314:
-----------------------------------
Labels: flake flaky-test (was: flaky-test)
> StreamingWordCountIT is flaky
> -----------------------------
>
> Key: BEAM-11314
> URL: https://issues.apache.org/jira/browse/BEAM-11314
> Project: Beam
> Issue Type: Bug
> Components: test-failures
> Reporter: Ahmet Altay
> Priority: P1
> Labels: flake, flaky-test
>
> Example: [https://ci-beam.apache.org/job/beam_PreCommit_Python_Commit/16401/consoleFull#gradle-task-235] (search for: py36:preCommitIT_streaming)
> job link: https://console.cloud.google.com/dataflow/jobs/us-central1/2020-11-19_18_25_20-8827839168269537580?project=apache-beam-testing
> Error:
> ======================================================================*18:16:37* FAIL: test_streaming_wordcount_it (apache_beam.examples.streaming_wordcount_it_test.StreamingWordCountIT)*18:16:37* ----------------------------------------------------------------------*18:16:37* Traceback (most recent call last):*18:16:37* File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/apache_beam/examples/streaming_wordcount_it_test.py", line 107, in test_streaming_wordcount_it*18:16:37* save_main_session=False)*18:16:37* File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/apache_beam/examples/streaming_wordcount.py", line 108, in run*18:16:37* output | beam.io.WriteToPubSub(known_args.output_topic)*18:16:37* File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/apache_beam/pipeline.py", line 568, in __exit__*18:16:37* self.result = self.run()*18:16:37* File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/apache_beam/pipeline.py", line 547, in run*18:16:37* return self.runner.run_pipeline(self, self._options)*18:16:37* File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/apache_beam/runners/dataflow/test_dataflow_runner.py", line 72, in run_pipeline*18:16:37* hc_assert_that(self.result, pickler.loads(on_success_matcher))*18:16:37* AssertionError: *18:16:37* Expected: (Test pipeline expected terminated in state: RUNNING and Expected 500 messages.)*18:16:37* but: Expected 500 messages. Got 523 messages. Diffs (item, count):*18:16:37* Expected but not in actual: dict_items([])*18:16:37* Unexpected: dict_items([(b'125: 1', 1), (b'399: 1', 1), (b'480: 1', 1), (b'495: 1', 1), (b'120: 1', 1), (b'115: 1', 1), (b'203: 1', 1), (b'236: 1', 1), (b'243: 1', 1), (b'322: 1', 1), (b'268: 1', 1), (b'173: 1', 1), (b'425: 1', 1), (b'363: 1', 1), (b'182: 1', 1), (b'445: 1', 1), (b'44: 1', 1), (b'437: 1', 1), (b'199: 1', 1), (b'298: 1', 1), (b'261: 1', 1), (b'380: 1', 1), (b'473: 1', 1)])*18:16:37*
--
This message was sent by Atlassian Jira
(v8.3.4#803005)