[
https://issues.apache.org/jira/browse/FLINK-31333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-31333.
----------------------------------
Resolution: Cannot Reproduce
> KafkaPartitionSplitReaderTest.testPendingRecordsGauge failed to create topic
> ----------------------------------------------------------------------------
>
> Key: FLINK-31333
> URL: https://issues.apache.org/jira/browse/FLINK-31333
> Project: Flink
> Issue Type: Sub-task
> Components: Connectors / Kafka
> Affects Versions: 1.15.3
> Reporter: Matthias Pohl
> Priority: Major
> Labels: test-stability
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=46765&view=logs&j=ce8f3cc3-c1ea-5281-f5eb-df9ebd24947f&t=918e890f-5ed9-5212-a25e-962628fb4bc5
> {code}
> Mar 03 03:17:58 [INFO] Running
> org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReaderTest
> java.util.concurrent.ExecutionException:
> org.apache.kafka.common.errors.TimeoutException: The request timed out.
> at
> org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
> at
> org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
> at
> org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)
> at
> org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:260)
> at
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.createTestTopic(KafkaTestEnvironmentImpl.java:175)
> at
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironment.createTestTopic(KafkaTestEnvironment.java:97)
> at
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase.createTestTopic(KafkaTestBase.java:216)
> at
> org.apache.flink.connector.kafka.testutils.KafkaSourceTestEnv.createTestTopic(KafkaSourceTestEnv.java:217)
> at
> org.apache.flink.connector.kafka.testutils.KafkaSourceTestEnv.setupTopic(KafkaSourceTestEnv.java:261)
> at
> org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReaderTest.testPendingRecordsGauge(KafkaPartitionSplitReaderTest.java:198)
> [...]
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
