[FLINK-28881] PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream test failure

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.16.0, gcp-pubsub-3.0.0
• Component/s: Connectors / Google Cloud PubSub
• Labels: auto-deprioritized-major test-stability
• Assignee: Unassigned
• Reporter: Leonard Xu
• Created: 09/Aug/22 03:52
• Updated: 10/Sep/23 22:35

Description

2022-08-09T03:14:22.0113691Z Aug 09 03:14:22 [ERROR] org.apache.flink.streaming.connectors.gcp.pubsub.PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream  Time elapsed: 1.867 s  <<< FAILURE!
2022-08-09T03:14:22.0114504Z Aug 09 03:14:22 java.lang.AssertionError: 
2022-08-09T03:14:22.0114903Z Aug 09 03:14:22 
2022-08-09T03:14:22.0115263Z Aug 09 03:14:22 Expected: <[1, 2, 3]>
2022-08-09T03:14:22.0115679Z Aug 09 03:14:22      but: was <[1, 2]>
2022-08-09T03:14:22.0116232Z Aug 09 03:14:22 	at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
2022-08-09T03:14:22.0116871Z Aug 09 03:14:22 	at org.junit.Assert.assertThat(Assert.java:964)
2022-08-09T03:14:22.0117580Z Aug 09 03:14:22 	at org.junit.Assert.assertThat(Assert.java:930)
2022-08-09T03:14:22.0118460Z Aug 09 03:14:22 	at org.apache.flink.streaming.connectors.gcp.pubsub.PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream(PubSubConsumingTest.java:119)

CI link: https://dev.azure.com/leonardBang/Azure_CI/_build/results?buildId=713&view=logs&j=3796201e-ea88-5776-0ea8-9ccca648a70c&t=8ca54b76-085e-5cf1-8060-2c500a258258