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