Dian Fu created FLINK-18534: ------------------------------- Summary: KafkaTableITCase.testKafkaDebeziumChangelogSource failed with "Topic 'changelog_topic' already exists" Key: FLINK-18534 URL: https://issues.apache.org/jira/browse/FLINK-18534 Project: Flink Issue Type: Test Components: Connectors / Kafka, Table SQL / API, Tests Affects Versions: 1.12.0 Reporter: Dian Fu
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=4350&view=logs&j=4be4ed2b-549a-533d-aa33-09e28e360cc8&t=0db94045-2aa0-53fa-f444-0130d6933518 {code} 2020-07-08T21:14:04.1626423Z [ERROR] Failures: 2020-07-08T21:14:04.1629804Z [ERROR] KafkaTableITCase.testKafkaDebeziumChangelogSource:66->KafkaTestBase.createTestTopic:197 Create test topic : changelog_topic failed, org.apache.kafka.common.errors.TopicExistsException: Topic 'changelog_topic' already exists. 2020-07-08T21:14:04.1630642Z [ERROR] Errors: 2020-07-08T21:14:04.1630986Z [ERROR] KafkaTableITCase.testKafkaDebeziumChangelogSource:83 Failed to write debezium... {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)