flinksql sink 丢失数据

[pass]

大佬们有碰到过 flinksql  sink 丢数据的情况吗，我sink时把table转换为stream   然后根据sink表的主键进行keby，再根据update after 和 delete俩类型进行数据的更新和删除，但是会出现丢个别数据的情况，更准确的说应该是插入后又被删除了