Flink CDC 3.1.0 pipeline 多表合一、分库分表 Mysql写入Doris yaml
·
多表合一 yaml:
source:
type: mysql
hostname: 172.xxx.xxx.xxx
port: 3306
username: root
password: xxx
tables: sync_db.\.*
server-id: 5400-5404
server-time-zone: Asia/Shanghai
sink:
type: doris
fenodes: 172.xxx.xxx.xxx:8030
username: root
password: xxx
table.create.properties.light_schema_change: true
route:
- source-table: sync_db.\.*
sink-table: sync_db.ods_sync_db
pipeline:
name: Sync MySQL Database to Doris
parallelism: 2
分库分表 yaml:
source:
type: mysql
hostname: 172.xxx.xxx.xxx
port: 3306
username: root
password: xxx
tables: sync_db.\.*
server-id: 5400-5404
server-time-zone: Asia/Shanghai
sink:
type: doris
fenodes: 172.xxx.xxx.xxx:8030
username: root
password: xxx
table.create.properties.light_schema_change: true
route:
- source-table: sync_db.teacher
sink-table: syc.ods_teacher
- source-table: sync_db.student
sink-table: syc.ods_student
pipeline:
name: Sync MySQL Database to Doris
parallelism: 2
更多推荐



所有评论(0)