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)
