[BEAM-13613] Beam examples failing for some runners: game_stats and leader_board

• Type: New Feature
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: examples-python, testing
• Labels: py-interrupts
• Assignee: Unassigned
• Reporter: Benjamin Gonzalez
• Created: 07/Jan/22 20:00
• Updated: 04/Jun/22 22:38

Description

 Integration tests of examples: game_stats and leader_board are failing for Spark, Flink, and Direct Runners with checksum error

 

AssertionError:  Expected: (Test pipeline expected terminated in state: RUNNING and Expected checksum is f3bc37a9581911f4288af5f3a70861d97265bf2f)      but: Expected checksum is f3bc37a9581911f4288af5f3a70861d97265bf2f Actual checksum is da39a3ee5e6b4b0d3255bfef95601890afd80709 

The returning checksum for those failing tests is calculated from an empty array because the query doesn't match the expected results.

 

https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Direct/7/testReport/

https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Spark/5/testReport/

https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/3/testReport/

Those tests run successfully on Dataflow.

https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/9/testReport/

Issue Links

• is related to: BEAM-12572 All beam examples should get continuously exercised