[BEAM-14269] PulsarIOTest.testReadFromSimpleTopic is very flaky

• Type: Bug
• Status: Open
• Priority: P1
• Resolution: Unresolved
• Component/s: test-failures
• Labels: flake
• Assignee: Marco Robles
• Reporter: Steve Niemitz
• Created: 06/Apr/22 21:39
• Updated: 05/Jun/22 01:25

Description

PulsarIOTest uses shared client across all tests [1], which is a race conditions when multiple tests run in parallel.  This manifests as frequent test failures.

[1] https://github.com/apache/beam/blob/master/sdks/java/io/pulsar/src/test/java/org/apache/beam/sdk/io/pulsar/PulsarIOTest.java#L62

Issue Links

• links to: GitHub Pull Request #17473