Flink写入Starrocks 主键模型更新异常

[U_1652769634603_1946]

【详述】Flink同步到SR的时候，删除操作我们发现有偶发性的情况，有时候业务库做了delete+insert后，在SR中有时候可以触发删除操作，有时候却不触发删除操作，导致数据量多。
【背景】业务库delete+insert
【业务影响】影响较大
【StarRocks版本】2.1.2
【Flink Connector】1.16
【集群规模】3个fe（3个 FE节点）+7 个be（7个BE节点）
【机器信息】CPU虚拟核/内存/网卡，32C/64G/万兆（2个节点128G，其他节点64G）
【附件】
mysql语句

FlinkSQL source语句

FlinkSQL sink语句

FlinkSQL insert语句

Starrocks语句

[U_1652691821777_1477]

这边追加一个业务侧的操作场景：业务系统修改记录，代码层是通过delete+insert的方式到达更新的目的，从op字段记录的时间点来看触发delete，insert的时间几乎一样，结果就是delete未同步到SR，insert则同步到SR侧了

[dongquan]

这种场景下正常删除再写入sr中应该是有一条数据，上面说的数据没有删除是又插入新数据导致的么？sr程序写的话只可能乱序不会说有数据丢失的

[U_1652691821777_1477]

目前现象是同时执行delete跟insert的情况下会发生该情况，且只有insert成功过来，依次先执行delete，后insert是正常的

[U_1652769634603_1946]

此问题可以关闭，不必显示出来

[U_1651041279778_8953]

请问这个问题解决了吗，我遇到了同样的问题？