flink-doris-connector-1.15-1.6.x

单纯 mysql cdc写入doris，
SET 'execution.checkpointing.interval' = '120s';
CREATE TABLE IF NOT EXISTS sync_purchase_info_optimization (
id BIGINT NOT NULL COMMENT '主键'
。。。。。
,PRIMARY KEY ( id ) NOT ENFORCED
) WITH (
'connector' = 'doris',
'fenodes' = '192.168.120.204:8030',
'table.identifier' = 'prong_platform.sync_purchase_info_optimization',
'username' = 'root',
'password'='******',
'sink.label-prefix' = 'prong_platform_sync_purchase_info_optimization_4',
'sink.properties.format' = 'json',
'sink.properties.read_json_by_line' = 'true',
'sink.enable-delete' = 'true'
);
sink端会一直反压，一条数据都写不进去，开启sink.enable.batch-mode=true之后方可写入!