[FLINK-18534] KafkaTableITCase.testKafkaDebeziumChangelogSource failed with "Topic 'changelog_topic' already exists"

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.12.0
• Fix Version/s: 1.11.1, 1.12.0
• Component/s: Connectors / Kafka, Table SQL / API, Tests
• Labels: pull-request-available test-stability
• Assignee: Jark Wu
• Reporter: Dian Fu
• Created: 09/Jul/20 02:16
• Updated: 27/Apr/21 18:08
• Resolved: 09/Jul/20 14:29

Description

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

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...

Issue Links

• links to: GitHub Pull Request #12858