Flaky test issue report (51)

[be...@gmail.com]

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)