[ 
https://issues.apache.org/jira/browse/FLINK-32268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749492#comment-17749492
 ] 

Qingsheng Ren commented on FLINK-32268:
---------------------------------------

I checked the log but found no clue... Probably some internal instability 
inside Kafka testing container. 

I'll move it out of 1.18 version as Kafka connector has been moved out of Flink 
main repo. 

> KafkaTableITCase.testKafkaSourceSinkWithBoundedTimestamp failed to create 
> topic
> -------------------------------------------------------------------------------
>
>                 Key: FLINK-32268
>                 URL: https://issues.apache.org/jira/browse/FLINK-32268
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Kafka
>    Affects Versions: 1.18.0
>            Reporter: Sergey Nuyanzin
>            Assignee: Qingsheng Ren
>            Priority: Critical
>              Labels: test-stability
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=49661&view=logs&j=aa18c3f6-13b8-5f58-86bb-c1cffb239496&t=502fb6c0-30a2-5e49-c5c2-a00fa3acb203&l=22373
> {noformat}
> Jun 06 01:54:31 Caused by: java.util.concurrent.ExecutionException: 
> org.apache.kafka.common.errors.TimeoutException: The request timed out.
> Jun 06 01:54:31       at 
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> Jun 06 01:54:31       at 
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> Jun 06 01:54:31       at 
> org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165)
> Jun 06 01:54:31       at 
> org.apache.flink.streaming.connectors.kafka.table.KafkaTableTestBase.createTestTopic(KafkaTableTestBase.java:140)
> Jun 06 01:54:31       ... 59 more
> {noformat}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to