[
https://issues.apache.org/jira/browse/FLINK-35540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35540:
----------------------------------
Assignee: linqigeng
> 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: linqigeng
> Assignee: linqigeng
> Priority: Major
> Labels: pull-request-available
>
> 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: UTC
> sink:
> 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)
