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-12322: FnApiRunnerTestWithGrpcAndMultiWorkers flaky (py precommit)
(https://issues.apache.org/jira/browse/BEAM-12322)
BEAM-12309: PubSubIntegrationTest.test_streaming_data_only flake
(https://issues.apache.org/jira/browse/BEAM-12309)
BEAM-12307: PubSubBigQueryIT.test_file_loads flake
(https://issues.apache.org/jira/browse/BEAM-12307)
BEAM-12303: Flake in PubSubIntegrationTest.test_streaming_with_attributes
(https://issues.apache.org/jira/browse/BEAM-12303)
BEAM-12293: FlinkSavepointTest.testSavepointRestoreLegacy flakes due to
FlinkJobNotFoundException (https://issues.apache.org/jira/browse/BEAM-12293)
BEAM-12291:
org.apache.beam.runners.flink.ReadSourcePortableTest.testExecution[streaming:
false] is flaky (https://issues.apache.org/jira/browse/BEAM-12291)
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-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-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-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-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-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-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-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)
