[Feature][cdc] Support Flink CDC pipeline task in FlinkSQL dialect

[aiwenmo]

Search before asking

• I had searched in the issues and found no similar feature requirement.

Description

source:
type: mysql
hostname: localhost
port: 3306
username: root
password: 123456
tables: app_db..*
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: 1

pipeline:
name: Sync MySQL Database to Doris
parallelism: 2

Use case

source:
type: mysql
hostname: localhost
port: 3306
username: root
password: 123456
tables: app_db..*
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: 1

pipeline:
name: Sync MySQL Database to Doris
parallelism: 2

Related issues

No response

Are you willing to submit a PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[aiwenmo]

[aiwenmo]

[aiwenmo]

[leonardBang]

Thanks @aiwenmo for driving this work, Niubility !

[aiwenmo]

[aiwenmo]

EXECUTE PIPELINE WITHYAML (
source:
  type: mysql
  hostname: localhost
  port: 3306
  username: root
  password: 123456
  tables: app_db.\.*
  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: 1

pipeline:
  name: Sync MySQL Database to Doris
  parallelism: 2
)

[aiwenmo]

Thanks @aiwenmo for driving this work, Niubility !

Thank you to the FlinkCDC community for designing and implementing a pipeline that is easy to integrate.