[FLINK-35540] flink-cdc-pipeline-connector-mysql lost table which database and table with the same name

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: cdc-3.1.0
• Fix Version/s: cdc-3.2.0, cdc-3.1.1
• Component/s: Flink CDC
• Labels: pull-request-available
• Assignee: linqigeng
• Reporter: linqigeng
• Created: 06/Jun/24 08:46
• Updated: 12/Jun/24 01:51
• Resolved: 12/Jun/24 01:51

Description

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:

java.lang.IllegalArgumentException: Cannot find any table by the option 'tables' = app.app 

How to reproduce

Create database and table all named `app`, then submit a pipeline job like this YAML defined:

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 

Issue Links

• links to: GitHub Pull Request #3396
• links to: GitHub Pull Request #3409