Matthias Pohl created FLINK-31333: ------------------------------------- Summary: 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
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)