flinkCDC mysql

1.起首必须在要同步到源端和目标端创建好表
2.源端flinksql语句如下：

1. DROP TABLE IF EXISTS FLINK_SOURCE_hrpt_dtl;
2. create table FLINK_SOURCE_hrpt_dtl(
3. `template_dtl_id`bigint NOT NULL ,
4.   `template_id`bigint NOT NULL COMMENT '报表模板ID,hrpt_template.template_id',
5.   `template_url` varchar(480)   COMMENT '模板路径',
6.   `template_content` string  COMMENT '模板内容',
7.   `lang` varchar(30)  NOT NULL COMMENT '模板语言',
8.   `enabled_flag` tinyint NOT NULL  COMMENT '启用标识',
9.   `tenant_id`bigint NOT NULL  COMMENT '租户ID,hpfm_tenant.tenant_id',
10.   `object_version_number`bigint NOT NULL  COMMENT '行版本号，用来处理锁',
11.   `creation_date` timestamp NOT NULL,
12.   `created_by`bigint NOT NULL ,
13.   `last_updated_by`bigint NOT NULL ,
14.   `last_update_date` timestamp NOT NULL,
15.         PRIMARY KEY (`template_dtl_id`) NOT ENFORCED
16. )with (
17. 'connector' = 'mysql-cdc',
18. 'hostname' = '1.6.2.13',
19. 'port' = '3306',
20. 'username' = 'test',
21. 'password' = 'test@123',
22. 'database-name' = 'report',
23. 'table-name' = 'hrpt_dtl',
24. 'scan.incremental.snapshot.

复制代码