[FLINK-30503] KafkaSourceITCase$IntegrationTests.testSavepoint failed with timeout

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Cannot Reproduce
• Affects Version/s: 1.17.0
• Component/s: Connectors / Kafka
• Labels: stale-assigned test-stability
• Assignee: Qingsheng Ren
• Reporter: Qingsheng Ren
• Created: 26/Dec/22 07:46
• Updated: 16/Oct/23 07:08
• Resolved: 16/Oct/23 07:08

Description

https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=44202&view=logs&j=aa18c3f6-13b8-5f58-86bb-c1cffb239496&t=502fb6c0-30a2-5e49-c5c2-a00fa3acb203&l=37262

[...]
Dec 24 01:36:26 [ERROR] org.apache.flink.connector.kafka.source.KafkaSourceITCase$IntegrationTests.testSavepoint(TestEnvironment, DataStreamSourceExternalContext, CheckpointingMode)[2]  Time elapsed: 35.447 s  <<< ERROR!
Dec 24 01:36:26 java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: The request timed out.
Dec 24 01:36:26 	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
Dec 24 01:36:26 	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
Dec 24 01:36:26 	at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165)
Dec 24 01:36:26 	at org.apache.flink.connector.kafka.testutils.KafkaSourceExternalContext.close(KafkaSourceExternalContext.java:160)
[...]

Issue Links

• relates to: FLINK-30879 KafkaShuffleITCase failed with multiple test failures due to a TimeoutException while creating topics