[BEAM-14019] Java Examples are failing for different runners

• Type: Test
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: examples-java, testing
• Assignee: Unassigned
• Reporter: Benjamin Gonzalez
• Created: 01/Mar/22 17:54
• Updated: 04/Jun/22 22:43

Description

With the recent addition of suites to continuously test Java examples in different runners,  some existing integration tests fail for different runners

• org.apache.beam.examples.WindowedWordCountIT.testWindowedWordCountInBatchDynamicSharding, fails in FlinkRunner with AssertionError, for DirectRunner and SparkRunner the test never finishes.
• org.apache.beam.examples.WindowedWordCountIT.testWindowedWordCountInStreamingStaticSharding fails in SparkRunner with error Failed to read from sharded output
• org.apache.beam.examples.cookbook.BigQueryTornadoesIT.testE2eBigQueryTornadoesWithStorageApiUsingQuery fails in FlinkRunner with Error deleting table, Not found: Dataset

 

Issue Links

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