[ 
https://issues.apache.org/jira/browse/BEAM-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478307#comment-17478307
 ] 

Benjamin Gonzalez commented on BEAM-13613:
------------------------------------------

I looked over the bigquery table to see the results of the pipeline, in 
leader_board test 
https://github.com/apache/beam/blob/65114a9c0ffaa68ac79c7ef071398973adb08682/sdks/python/apache_beam/examples/complete/game/leader_board_it_test.py#L116,
 the query of the bigqueryMatcher expects a total_score of 5000 but sometimes 
the last result is around 4760 or less, not sure why.

> Beam examples failing for some runners: game_stats and leader_board
> -------------------------------------------------------------------
>
>                 Key: BEAM-13613
>                 URL: https://issues.apache.org/jira/browse/BEAM-13613
>             Project: Beam
>          Issue Type: New Feature
>          Components: examples-python, testing
>            Reporter: Benjamin Gonzalez
>            Priority: P3
>
>  Integration tests of examples: 
> [game_stats|https://github.com/apache/beam/blob/master/sdks/python/apache_beam/examples/complete/game/game_stats_it_test.py]
>  and 
> [leader_board|https://github.com/apache/beam/blob/master/sdks/python/apache_beam/examples/complete/game/leader_board_it_test.py]
>  are failing for Spark, Flink, and Direct Runners with checksum error
>  
> {code:java}
> AssertionError:  Expected: (Test pipeline expected terminated in state: 
> RUNNING and Expected checksum is f3bc37a9581911f4288af5f3a70861d97265bf2f)    
>   but: Expected checksum is f3bc37a9581911f4288af5f3a70861d97265bf2f Actual 
> checksum is da39a3ee5e6b4b0d3255bfef95601890afd80709 {code}
> 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/]



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to