[BEAM-12309] PubSubIntegrationTest.test_streaming_data_only flake

• Type: Bug
• Status: Resolved
• Priority: P1
• Resolution: Cannot Reproduce
• Fix Version/s: Missing
• Component/s: io-py-gcp, test-failures
• Labels: flake
• Assignee: Unassigned
• Reporter: Brian Hulette
• Created: 07/May/21 15:47
• Updated: 13/Jan/22 21:49
• Resolved: 25/Aug/21 14:16

Description

Saw this here: https://ci-beam.apache.org/job/beam_PostCommit_Python37/3767/

Expected: (Test pipeline expected terminated in state: RUNNING and Expected 4 messages.)
     but: Expected 4 messages. Got 0 messages. Diffs (item, count):
  Expected but not in actual: dict_items([(b'data001-seen', 1), (b'data002-seen', 1), (b'data003\xab\xac-seen', 1), (b'data004\xab\xac-seen', 1)])
  Unexpected: dict_items([])