请问，Flink CDC这种情况导致被压如何解决呢？insert into dws_order_

请问，Flink CDC这种情况导致被压如何解决呢？insert into dws_order_statistics_record_sinkselect a.sellerTenantId, a.customerId, a.deptId, a.creatorId, a.createDate, COUNT(a.orderNo) as totalNum, -- 订单总量 COUNT(a.orderNo) FILTER (WHERE a.orderStatus in(6, 7, 12, 16)) as cjTotalNum, -- 成交总量 SUM(IFNULL(a.payableAmount, 0.00)) AS payableTotalAmount -- 应收金额FROM oms_order_source awhere a.orderType = 2 and a.orderStatus <>4 and a.sellerTenantId<>-1 and a.deptId is not nullgroup by a.sellerTenantId, a.customerId, a.deptId, a.creatorId, a.createDate; 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' = 'mysql-cdc',-- 'scan.startup.mode'='latest-offset', 'hostname' = '*', 'port' = '3306', 'username' = '', 'password' = '*', 'database-name' =' ', 'table-name' = '*');