[
https://issues.apache.org/jira/browse/FLINK-30236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17640464#comment-17640464
]
Gabor Somogyi commented on FLINK-30236:
---------------------------------------
Topic creation can fail because of the Kafka broker. This is hard to find out
because such cases we need broker logs which is running in a different
container. Double pain how to debug deadlock from logs.
The test most probably is passing because Kafka broker auto topic creation is
enabled by default (auto.create.topics.enable). When it's enabled then manual
topic creation is just additional code because any producer can create
arbitrary topics :)
> UpsertKafkaTableITCase failed due to timeout when creating a topic
> ------------------------------------------------------------------
>
> Key: FLINK-30236
> URL: https://issues.apache.org/jira/browse/FLINK-30236
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: 1.17.0
> Reporter: Matthias Pohl
> Priority: Major
> Labels: test-stability
>
> The following build failed due to a timeout when creating the topic.
> {code:java}
> Nov 28 16:25:44 [ERROR] Tests run: 15, Failures: 0, Errors: 1, Skipped: 0,
> Time elapsed: 72.815 s <<< FAILURE! - in
> org.apache.flink.streaming.connectors.kafka.table.UpsertKafkaTableITCase
> Nov 28 16:25:44 [ERROR] UpsertKafkaTableITCase.testAggregate Time elapsed:
> 31.629 s <<< ERROR!
> Nov 28 16:25:44 java.lang.IllegalStateException: Fail to create topic
> [word_count_json partitions: 4 replication factor: 1].
> Nov 28 16:25:44 at
> org.apache.flink.streaming.connectors.kafka.table.KafkaTableTestBase.createTestTopic(KafkaTableTestBase.java:143)
> Nov 28 16:25:44 at
> org.apache.flink.streaming.connectors.kafka.table.UpsertKafkaTableITCase.testAggregate(UpsertKafkaTableITCase.java:78)
> Nov 28 16:25:44 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
> Method)
> Nov 28 16:25:44 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> [...] {code}
> I suspect this being a general issue with providing timeouts for tests.
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=43566&view=logs&j=aa18c3f6-13b8-5f58-86bb-c1cffb239496&t=502fb6c0-30a2-5e49-c5c2-a00fa3acb203&l=37623
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
