chamikaramj opened a new issue, #23907: URL: https://github.com/apache/beam/issues/23907
### What happened? Seems like following Python examples are failing for Flink and Spark on 2.43.0 release branch. - bigquery_tornadoes - hourly_team_score - filters_test For example, https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Spark_PR/14/ https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink_PR/12/ For bigquery_tornadoes, the error is following. RuntimeError: Pipeline BeamApp-jenkins-1028002928-4325f8c5_d8258ff0-6727-4335-867f-56bc846d9f3e failed in state FAILED: java.lang.IllegalArgumentException: PCollectionNodes [PCollectionNode{id=ref_PCollection_PCollection_52, PCollection=unique_name: "61Write/BigQueryBatchFileLoads/TriggerLoadJobsWithoutTempTables.None" coder_id: "ref_Coder_FastPrimitivesCoder_3" is_bounded: BOUNDED windowing_strategy_id: "ref_Windowing_Windowing_1" }] were consumed but never produced I found https://github.com/apache/beam/issues/21300 that probably explain some example failures but this doesn't explain all failures above. Valentyn, are there any known issues that explain these failures ? ### Issue Priority Priority: 0 ### Issue Component Component: examples-python -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
