[FLINK-23971] PulsarSourceITCase.testIdleReader failed on azure

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.14.0
• Fix Version/s: 1.14.0
• Component/s: Connectors / Pulsar
• Labels: pull-request-available test-stability
• Assignee: Hang Ruan
• Reporter: Roman Khachatryan
• Created: 25/Aug/21 15:21
• Updated: 12/Jan/22 14:24
• Resolved: 01/Sep/21 09:54

Description

[INFO] Running org.apache.flink.connector.pulsar.source.PulsarSourceITCase
[ERROR] Tests run: 8, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 353.527 s <<< FAILURE! - in org.apache.flink.connector.pulsar.source.PulsarSourceITCase
[ERROR] testIdleReader{TestEnvironment, ExternalContext}[2]  Time elapsed: 4.549 s  <<< FAILURE!
java.lang.AssertionError:

Expected: Records consumed by Flink should be identical to test data and preserve the order in multiple splits
     but: Unexpected record 'tj7MpFRWX95GzBpSF3CCjxKSal6bRhR0aF'
   at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
   at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:8)
   at org.apache.flink.connectors.test.common.testsuites.SourceTestSuiteBase.testIdleReader(SourceTestSuiteBase.java:193)

https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=22819&view=logs&j=fc5181b0-e452-5c8f-68de-1097947f6483&t=995c650b-6573-581c-9ce6-7ad4cc038461&l=24448

This is the same error as in FLINK-23828 (kafka).

Issue Links

• relates to: FLINK-23828 KafkaSourceITCase.testIdleReader fails on azure
• links to: GitHub Pull Request #17049