This is your daily summary of Beam's current flaky tests.
These are P1 issues because they have a major negative impact on the
community and make it hard to determine the quality of the software.
https://github.com/apache/beam/issues/21714:
PulsarIOTest.testReadFromSimpleTopic is very flaky
https://github.com/apache/beam/issues/21709:
beam_PostCommit_Java_ValidatesRunner_Samza Failing
https://github.com/apache/beam/issues/21708: beam_PostCommit_Java_DataflowV2,
testBigQueryStorageWrite30MProto failing consistently
https://github.com/apache/beam/issues/21707: GroupByKeyTest BasicTests
testLargeKeys100MB flake (on ULR)
https://github.com/apache/beam/issues/21706: Flaky timeout in github Python
unit test action
StatefulDoFnOnDirectRunnerTest.test_dynamic_timer_clear_then_set_timer
https://github.com/apache/beam/issues/21704: beam_PostCommit_Java_DataflowV2
failures parent bug
https://github.com/apache/beam/issues/21701: beam_PostCommit_Java_DataflowV1
failing with a variety of flakes and errors
https://github.com/apache/beam/issues/21698: Docker Snapshots failing to be
published since April 14th
https://github.com/apache/beam/issues/21696: Flink Tests failure :
java.lang.NoClassDefFoundError: Could not initialize class
org.apache.beam.runners.core.construction.SerializablePipelineOptions
https://github.com/apache/beam/issues/21643: FnRunnerTest with non-trivial
(order 1000 elements) numpy input flakes in non-cython environment
https://github.com/apache/beam/issues/21629: Multiple XVR Suites having similar
flakes simultaneously
https://github.com/apache/beam/issues/21587: beam_PreCommit_PythonDocs failing
(jinja2)
https://github.com/apache/beam/issues/21540: Jenkins worker sometimes crashes
while running Python Flink pipeline
https://github.com/apache/beam/issues/21480: flake:
FlinkRunnerTest.testEnsureStdoutStdErrIsRestored
https://github.com/apache/beam/issues/21474: Flaky tests: Gradle build daemon
disappeared unexpectedly
https://github.com/apache/beam/issues/21472: Dataflow streaming tests failing
new AfterSynchronizedProcessingTime test
https://github.com/apache/beam/issues/21471: Flakes: Failed to load cache entry
https://github.com/apache/beam/issues/21470: Test flake: test_split_half_sdf
https://github.com/apache/beam/issues/21469: beam_PostCommit_XVR_Flink flaky:
Connection refused
https://github.com/apache/beam/issues/21468:
beam_PostCommit_Python_Examples_Dataflow failing
https://github.com/apache/beam/issues/21467: GBK and CoGBK streaming Java load
tests failing
https://github.com/apache/beam/issues/21464: GroupIntoBatchesTest is failing
https://github.com/apache/beam/issues/21463: NPE in Flink Portable
ValidatesRunner streaming suite
https://github.com/apache/beam/issues/21462: Flake in
org.apache.beam.sdk.io.mqtt.MqttIOTest.testReadObject: Address already in use
https://github.com/apache/beam/issues/21333: Flink testParDoRequiresStableInput
flaky
https://github.com/apache/beam/issues/21271: pubsublite.ReadWriteIT flaky in
beam_PostCommit_Java_DataflowV2
https://github.com/apache/beam/issues/21270:
org.apache.beam.sdk.transforms.CombineTest$WindowingTests.testWindowedCombineGloballyAsSingletonView
flaky on Dataflow Runner V2
https://github.com/apache/beam/issues/21266:
org.apache.beam.sdk.transforms.ParDoLifecycleTest.testTeardownCalledAfterExceptionInProcessElementStateful
is flaky in Java ValidatesRunner Flink suite.
https://github.com/apache/beam/issues/21264: beam_PostCommit_Python36 -
CrossLanguageSpannerIOTest - flakey failing
https://github.com/apache/beam/issues/21261:
org.apache.beam.runners.dataflow.worker.fn.logging.BeamFnLoggingServiceTest.testMultipleClientsFailingIsHandledGracefullyByServer
is flaky
https://github.com/apache/beam/issues/21242:
org.apache.beam.sdk.transforms.ParDoLifecycleTest.testTeardownCalledAfterExceptionInStartBundle
is flaky in Java Spark ValidatesRunner suite
https://github.com/apache/beam/issues/21121:
apache_beam.examples.streaming_wordcount_it_test.StreamingWordCountIT.test_streaming_wordcount_it
flakey
https://github.com/apache/beam/issues/21120: beam_PostRelease_NightlySnapshot
failed
https://github.com/apache/beam/issues/21118:
PortableRunnerTestWithExternalEnv.test_pardo_timers flaky
https://github.com/apache/beam/issues/21116: Python PreCommit flaking in
PipelineOptionsTest.test_display_data
https://github.com/apache/beam/issues/21114: Already Exists: Dataset
apache-beam-testing:python_bq_file_loads_NNN
https://github.com/apache/beam/issues/21113:
testTwoTimersSettingEachOtherWithCreateAsInputBounded flaky
https://github.com/apache/beam/issues/21104: Flaky:
apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTestWithGrpcAndMultiWorkers
https://github.com/apache/beam/issues/20981: Python precommit flaky: Failed to
read inputs in the data plane
https://github.com/apache/beam/issues/20977: SamzaStoreStateInternalsTest is
flaky
https://github.com/apache/beam/issues/20976:
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized.test_flink_metrics
is flaky
https://github.com/apache/beam/issues/20975:
org.apache.beam.runners.flink.ReadSourcePortableTest.testExecution[streaming:
false] is flaky
https://github.com/apache/beam/issues/20974: Python GHA PreCommits flake with
grpc.FutureTimeoutError on SDK harness startup
https://github.com/apache/beam/issues/20937:
PubsubTableProviderIT.testSQLSelectsArrayAttributes[0] failing in SQL PostCommit
https://github.com/apache/beam/issues/20817: Bigquery Read tests are flaky on
Flink runner in Python PostCommit suites
https://github.com/apache/beam/issues/20815:
testTeardownCalledAfterExceptionInProcessElement flakes on direct runner.
https://github.com/apache/beam/issues/20690:
PortableRunnerTestWithSubprocesses.test_register_finalizations flaky on macOS
https://github.com/apache/beam/issues/20331:
org.apache.beam.sdk.io.mongodb.MongoDbIOTest.testReadWithAggregate is flaky
https://github.com/apache/beam/issues/19816:
MetricsTest$AttemptedMetricTests.testAllAttemptedMetrics is flaky on
DirectRunner
https://github.com/apache/beam/issues/19814: Flakes in
ParDoLifecycleTest.testTeardownCalledAfterExceptionInStartBundleStateful for
Direct, Spark, Flink
https://github.com/apache/beam/issues/19734:
WatchTest.testMultiplePollsWithManyResults flake: Outputs must be in timestamp
order (sickbayed)
