[FLINK-26177] PulsarSourceITCase.testScaleDown fails with timeout

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.15.0, 1.16.0
• Fix Version/s: 1.16.0, 1.15.2, 1.14.6
• Component/s: Connectors / Pulsar
• Labels: auto-deprioritized-critical pull-request-available stale-blocker test-stability
• Assignee: Yufan Sheng
• Reporter: Matthias Pohl
• Created: 16/Feb/22 08:00
• Updated: 14/Aug/22 14:54
• Resolved: 14/Aug/22 14:54

Description

We observed a build failure caused by PulsarSourceITCase.testScaleDown:

Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 431.023 s <<< FAILURE! - in org.apache.flink.connector.pulsar.source.PulsarSourceITCase
Feb 15 20:56:02 [ERROR] org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, DataStreamSourceExternalContext, CheckpointingMode)[2]  Time elapsed: 138.444 s  <<< FAILURE!
Feb 15 20:56:02 java.lang.AssertionError: 
Feb 15 20:56:02 
Feb 15 20:56:02 Expecting
Feb 15 20:56:02   <CompletableFuture[Incomplete]>
Feb 15 20:56:02 to be completed within 2M.
Feb 15 20:56:02 
Feb 15 20:56:02 exception caught while trying to get the future result: java.util.concurrent.TimeoutException
Feb 15 20:56:02 	at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784)
[...]

Issue Links

• is blocked by: FLINK-27399 Pulsar connector didn't set start consuming position correctly
• is related to: FLINK-26721 PulsarSourceITCase.testSavepoint failed on azure pipeline
• links to: GitHub Pull Request #18798
• links to: GitHub Pull Request #18838