[
https://issues.apache.org/jira/browse/FLINK-35540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qigeng Lin updated FLINK-35540:
-------------------------------
Description:
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}
was:
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}
> 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
> Priority: Major
>
> 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)
