Flink CDC中同一个sql同步到mysql少数据，同步到 es 没有问题，什么原因？

"Flink CDC中 同一个sql 同步到mysql 少数据，同步到 es 没有问题，是不是同步到mysql的时候需要做什么特殊处理，同步的sql :SET 'pipeline.name' = 'batch_order_statistics_job';SET 'table.exec.resource.default-parallelism'= '2';SET 'sql-client.execution.result-mode' = 'tableau';-- 订单主表CREATE TABLE if not exists oms_order_source( id bigint COMMENT 'ID', sellerTenantId bigint COMMENT '租户Id', orderNo STRING COMMENT '订单号', orderType tinyint COMMENT '订单类型(1:增值商品/2:普通商品/3:物流)', orderStatus tinyint COMMENT '订单状态()', deptId bigint COMMENT '部门Id', customerId bigint COMMENT '客户id', payableAmount DECIMAL(10, 2) COMMENT '应付金额', creatorId bigint COMMENT '下单人', createTime TIMESTAMP(3) COMMENT '下单时间', createDate as TO_DATE(DATE_FORMAT(createTime,'yyyy-MM-dd')) comment '下单日期', PRIMARY KEY (id) NOT ENFORCED) comment '订单主表映射信息'with ( 'connector' = 'jdbc',-- 'scan.startup.mode'='latest-offset', -- 'server-id'='5400-5408', -- 'hostname' = '192.168.2.252', 'url' = 'jdbc:mysql://xxx:3306/cloud_account_system', 'username' = 'xxx', 'password' = 'xxx', 'sink.parallelism' ='4', 'table-name' = 'oms_order');-- 订单统计CREATE TABLE if not exists dws_order_sync_record_sink( id BIGINT COMMENT '主键', sellerTenantId BIGINT COMMENT '租户Id', customerId BIGINT COMMENT '客户Id', deptId BIGINT COMMENT '部门Id', creatorId BIGINT COMMENT '下单人', createDate DATE COMMENT '下单日期', orderNo STRING COMMENT '订单总量', payableAmount DECIMAL(10, 2) COMMENT '应收金额', PRIMARY KEY (sellerTenantId, deptId, creatorId, createDate) NOT ENFORCED)WITH ('connector' = 'jdbc', -- 'url' = 'jdbc:mysql://192.168.2.252:3306/cloud_account_system', -- 'username' = 'cloud_test', -- 'password' = 'Js81#5q2Pr', 'url' = 'jdbc:mysql://xxxx:3306/cloud_account_system', 'username' = 'xxx', 'password' = 'xxx', -- 'sink.buffer-flush.max-rows'='1000', 'sink.parallelism' ='4', 'table-name' = 'dws_order_sync_record');-- 订单数据统计-- insert into dws_order_sync_record_sinkselect a.id, a.sellerTenantId, a.customerId, a.deptId, a.creatorId, a.createDate, a.orderNo, a.payableAmountFROM oms_order_source awhere a.orderType = 2 and a.orderStatus <>4 and a.sellerTenantId<>-1 and a.deptId is not null;

不查询，只是打印，数据量是对的，只要插入到mysql 数据就少了，我看了下都是用的主键，都没一做聚合，不应该出现主键一样的情况。"