Flink CDC中select 的时候，看了下，是正常的，就是插入得时候偶问题，什么原因？

"Flink CDC中select 的时候，看了下，是正常的，就是插入得时候偶问题，什么原因？


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_sink
select a.id,
a.sellerTenantId,
a.customerId,
a.deptId,
a.creatorId,
a.createDate,
a.orderNo,
a.payableAmount
FROM oms_order_source a
where a.orderType = 2
and a.orderStatus <>4
and a.sellerTenantId<>-1
and a.deptId is not null;
"