Failed: Timeout >1800.0s
self = <apache_beam.examples.wordcount_it_test.WordCountIT testMethod=test_wordcount_it>

    @pytest.mark.it_postcommit
    @pytest.mark.it_validatescontainer
    def test_wordcount_it(self):
>     self._run_wordcount_it(wordcount.run)

apache_beam/examples/wordcount_it_test.py:50: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/examples/wordcount_it_test.py:150: in _run_wordcount_it
    run_wordcount(
apache_beam/examples/wordcount.py:109: in run
    result = pipeline.run()
apache_beam/pipeline.py:567: in run
    return Pipeline.from_runner_api(
apache_beam/pipeline.py:594: in run
    return self.runner.run_pipeline(self, self._options)
apache_beam/runners/dataflow/test_dataflow_runner.py:70: in run_pipeline
    hc_assert_that(self.result, pickler.loads(on_success_matcher))
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/hamcrest/core/core/allof.py:26: in matches
    if not matcher.matches(item):
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/hamcrest/core/base_matcher.py:39: in matches
    match_result = self._matches(item)
apache_beam/testing/pipeline_verifiers.py:140: in _matches
    read_lines = self._read_with_retry()
apache_beam/utils/retry.py:298: in wrapper
    return fun(*args, **kwargs)
apache_beam/testing/pipeline_verifiers.py:129: in _read_with_retry
    for line in f:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <apache_beam.io.gcp.gcsio.BeamBlobReader object at 0x78f79f270be0>
size = 1

>   def read(self, size=-1):
E   Failed: Timeout >1800.0s

apache_beam/io/gcp/gcsio.py:597: Failed