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.
BEAM-12200: SamzaStoreStateInternalsTest is flaky (https://issues.apache.org/jira/browse/BEAM-12200) BEAM-12163: Python GHA PreCommits flake with grpc.FutureTimeoutError on SDK harness startup (https://issues.apache.org/jira/browse/BEAM-12163) BEAM-12061: beam_PostCommit_SQL failing on KafkaTableProviderIT.testFakeNested (https://issues.apache.org/jira/browse/BEAM-12061) BEAM-12020: :sdks:java:container:java8:docker failing missing licenses (https://issues.apache.org/jira/browse/BEAM-12020) BEAM-12019: apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized.test_flink_metrics is flaky (https://issues.apache.org/jira/browse/BEAM-12019) BEAM-11792: Python precommit failed (flaked?) installing package (https://issues.apache.org/jira/browse/BEAM-11792) BEAM-11733: [beam_PostCommit_Java] [testFhirIO_Import|export] flaky (https://issues.apache.org/jira/browse/BEAM-11733) BEAM-11666: apache_beam.runners.interactive.recording_manager_test.RecordingManagerTest.test_basic_execution is flaky (https://issues.apache.org/jira/browse/BEAM-11666) BEAM-11662: elasticsearch tests failing (https://issues.apache.org/jira/browse/BEAM-11662) BEAM-11661: hdfsIntegrationTest flake: network not found (py38 postcommit) (https://issues.apache.org/jira/browse/BEAM-11661) BEAM-11646: beam_PostCommit_XVR_Spark failing (https://issues.apache.org/jira/browse/BEAM-11646) BEAM-11645: beam_PostCommit_XVR_Flink failing (https://issues.apache.org/jira/browse/BEAM-11645) BEAM-11541: testTeardownCalledAfterExceptionInProcessElement flakes on direct runner. (https://issues.apache.org/jira/browse/BEAM-11541) BEAM-11540: Linter sometimes flakes on apache_beam.dataframe.frames_test (https://issues.apache.org/jira/browse/BEAM-11540) BEAM-10995: Java + Universal Local Runner: WindowingTest.testWindowPreservation fails (https://issues.apache.org/jira/browse/BEAM-10995) BEAM-10987: stager_test.py::StagerTest::test_with_main_session flaky on windows py3.6,3.7 (https://issues.apache.org/jira/browse/BEAM-10987) BEAM-10968: flaky test: org.apache.beam.sdk.metrics.MetricsTest$AttemptedMetricTests.testAttemptedDistributionMetrics (https://issues.apache.org/jira/browse/BEAM-10968) BEAM-10955: Flink Java Runner test flake: Could not find Flink job (https://issues.apache.org/jira/browse/BEAM-10955) BEAM-10923: Python requirements installation in docker container is flaky (https://issues.apache.org/jira/browse/BEAM-10923) BEAM-10899: test_FhirIO_exportFhirResourcesGcs flake with OOM (https://issues.apache.org/jira/browse/BEAM-10899) BEAM-10866: PortableRunnerTestWithSubprocesses.test_register_finalizations flaky on macOS (https://issues.apache.org/jira/browse/BEAM-10866) BEAM-10763: Spotless flake (NullPointerException) (https://issues.apache.org/jira/browse/BEAM-10763) BEAM-10590: BigQueryQueryToTableIT flaky: test_big_query_new_types (https://issues.apache.org/jira/browse/BEAM-10590) BEAM-10519: MultipleInputsAndOutputTests.testParDoWithSideInputsIsCumulative flaky on Samza (https://issues.apache.org/jira/browse/BEAM-10519) BEAM-10504: Failure / flake in ElasticSearchIOTest > testWriteFullAddressing and testWriteWithIndexFn (https://issues.apache.org/jira/browse/BEAM-10504) BEAM-10501: CheckGrafanaStalenessAlerts and PingGrafanaHttpApi fail with Connection refused (https://issues.apache.org/jira/browse/BEAM-10501) BEAM-10485: Failure / flake: ElasticsearchIOTest > testWriteWithIndexFn (https://issues.apache.org/jira/browse/BEAM-10485) BEAM-10272: Failure in CassandraIOTest init: cannot create cluster due to netty link error (https://issues.apache.org/jira/browse/BEAM-10272) BEAM-9649: beam_python_mongoio_load_test started failing due to mismatched results (https://issues.apache.org/jira/browse/BEAM-9649) BEAM-9392: TestStream tests are all flaky (https://issues.apache.org/jira/browse/BEAM-9392) BEAM-9232: BigQueryWriteIntegrationTests is flaky coercing to Unicode (https://issues.apache.org/jira/browse/BEAM-9232) BEAM-9119: apache_beam.runners.portability.fn_api_runner_test.FnApiRunnerTest[...].test_large_elements is flaky (https://issues.apache.org/jira/browse/BEAM-9119) BEAM-8879: IOError flake in PortableRunnerTest (https://issues.apache.org/jira/browse/BEAM-8879) BEAM-8101: Flakes in ParDoLifecycleTest.testTeardownCalledAfterExceptionInStartBundleStateful for Direct, Spark, Flink (https://issues.apache.org/jira/browse/BEAM-8101) BEAM-8035: [beam_PreCommit_Java_Phrase] [WatchTest.testMultiplePollsWithManyResults] Flake: Outputs must be in timestamp order (https://issues.apache.org/jira/browse/BEAM-8035) BEAM-7992: Unhandled type_constraint in apache_beam.io.gcp.bigquery_write_it_test.BigQueryWriteIntegrationTests.test_big_query_write_new_types (https://issues.apache.org/jira/browse/BEAM-7992) BEAM-7865: Java precommit Samza tests opening RocksDB flaky (https://issues.apache.org/jira/browse/BEAM-7865) BEAM-7827: MetricsTest$AttemptedMetricTests.testAllAttemptedMetrics is flaky on DirectRunner (https://issues.apache.org/jira/browse/BEAM-7827) BEAM-7752: Java Validates DirectRunner: testTeardownCalledAfterExceptionInFinishBundleStateful flaky (https://issues.apache.org/jira/browse/BEAM-7752) BEAM-7469: [beam_PostCommit_Java_Nexmark_Dataflow] [:sdks:java:testing:nexmark:run] Job was unexpectedly updated (https://issues.apache.org/jira/browse/BEAM-7469) BEAM-6804: [beam_PostCommit_Java] [PubsubReadIT.testReadPublicData] Timeout waiting on Sub (https://issues.apache.org/jira/browse/BEAM-6804) BEAM-5907: Dataflow worker unit test suite has thread-unsafe use of mockito (https://issues.apache.org/jira/browse/BEAM-5907) BEAM-5814: Failure in RegisterAndProcessBundleOperationTest.testProcessingBundleHandlesMultimapSideInputRequests (https://issues.apache.org/jira/browse/BEAM-5814) BEAM-5286: [beam_PostCommit_Java_GradleBuild][org.apache.beam.examples.subprocess.ExampleEchoPipelineTest.testExampleEchoPipeline][Flake] .sh script: text file busy. (https://issues.apache.org/jira/browse/BEAM-5286) BEAM-5172: org.apache.beam.sdk.io.elasticsearch/ElasticsearchIOTest is flaky (https://issues.apache.org/jira/browse/BEAM-5172) BEAM-5171: org.apache.beam.sdk.io.CountingSourceTest.test[Un]boundedSourceSplits tests are flaky in Spark runner (https://issues.apache.org/jira/browse/BEAM-5171) BEAM-5150: MqttIOTest.testRead is flaky (https://issues.apache.org/jira/browse/BEAM-5150) BEAM-5070: nexmark.sources.UnboundedEventSourceTest.resumeFromCheckpoint is flaky (https://issues.apache.org/jira/browse/BEAM-5070) BEAM-3604: MqttIOTest testReadNoClientId failure timeout flaky test (https://issues.apache.org/jira/browse/BEAM-3604)