tvalentyn opened a new issue, #32069:
URL: https://github.com/apache/beam/issues/32069
### What happened?
The test_batch_size_with_auto_sharding scenario seems to become flaky
recently; I encountered this error in coverage test suite on some seemingly
unrelated PRs:
```
=================================== FAILURES
===================================
____ PipelineBasedStreamingInsertTest.test_batch_size_with_auto_sharding_0
_____
[gw5] linux -- Python 3.8.18
/runner/_work/beam/beam/sdks/python/test-suites/tox/py38/build/srcs/sdks/python/target/.tox-py38-cloudcoverage/py38-cloudcoverage/bin/python
a = (<apache_beam.io.gcp.bigquery_test.PipelineBasedStreamingInsertTest
testMethod=test_batch_size_with_auto_sharding_0>,)
kw = {}
@wraps(func)
def standalone_func(*a, **kw):
> return func(*(a + p.args), **p.kwargs, **kw)
target/.tox-py38-cloudcoverage/py38-cloudcoverage/lib/python3.8/site-packages/parameterized/parameterized.py:620:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _
apache_beam/io/gcp/bigquery_test.py:2239: in
test_batch_size_with_auto_sharding
self.assertEqual(out1['colA_values'], ['value1', 'value3'])
E AssertionError: Lists differ: ['value1', 'value5'] != ['value1',
'value3']
E
E First differing element 1:
E 'value5'
E 'value3'
E
E - ['value1', 'value5']
E ? ^
E
E + ['value1', 'value3']
E ? ^
```
=============================== warnings summary
===============================
https://github.com/apache/beam/actions/runs/10219876243/job/28279049265?pr=32066
### Issue Failure
Failure: Test is flaky
### Issue Priority
Priority: 1 (unhealthy code / failing or flaky postcommit so we cannot be
sure the product is healthy)
### Issue Components
- [X] Component: Python SDK
- [ ] Component: Java SDK
- [ ] Component: Go SDK
- [ ] Component: Typescript SDK
- [X] Component: IO connector
- [ ] Component: Beam YAML
- [ ] Component: Beam examples
- [ ] Component: Beam playground
- [ ] Component: Beam katas
- [ ] Component: Website
- [ ] Component: Infrastructure
- [ ] Component: Spark Runner
- [ ] Component: Flink Runner
- [ ] Component: Samza Runner
- [ ] Component: Twister2 Runner
- [ ] Component: Hazelcast Jet Runner
- [ ] Component: Google Cloud Dataflow Runner
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
