Qigeng Lin created FLINK-35540: ---------------------------------- Summary: flink-cdc-pipeline-connector-mysql lost table which database and table with the same name Key: FLINK-35540 URL: https://issues.apache.org/jira/browse/FLINK-35540 Project: Flink Issue Type: Bug Components: Flink CDC Affects Versions: cdc-3.1.0 Reporter: Qigeng Lin
h1. Description When the parameter of 'tables' in mysql pipeline job contains a table which database and table are with the same name like 'app.app', the job will fail and the error meaasge is like: {code:java} java.lang.IllegalArgumentException: Cannot find any table by the option 'tables' = app.app {code} h1. How to reproduce Create database and table all named `{{{}app`{}}}, then submit a pipeline job like this YAML defined: {code:java} source: type: mysql hostname: localhost port: 3306 username: root password: 123456 tables: app.app server-id: 5400-5404 server-time-zone: UTCsink: type: doris fenodes: 127.0.0.1:8030 username: root password: "" table.create.properties.light_schema_change: true table.create.properties.replication_num: 1pipeline: name: Sync MySQL Database to Doris parallelism: 2 {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)