有主键吗？ 有的话不会触发delete 才对
在 2020-09-28 15:54:49，"Leonard Xu" <xbjt...@gmail.com> 写道：
>
>
>> 在 2020年9月15日，16:52，LittleFall <1578166...@qq.com> 写道：
>>
>> 谢谢，请问有相关的 issue 链接吗
>>
>>
>>
>> --
>> Sent from: http://apache-flink.147419.n8.nabble.com/
>
>To @LItteFall :
>
>没有对应的issue，因为是在修复changlog
>issue[1]时在这个issue里一起修复的，代码可以看下TableBufferReducedStatementExecutor里reduceBuffer保证是对同key上得不同操作顺序执行的。
>
>To @Michael Ran:
>
>update 怎么触发的 delete 哦？
>
>LItteFall 是在数据库的表中触发了update操作，然后数据库的binlog通过 CDC工具 canal 以 canal-json
>格式写入到kafka的表中，一个update 会对应UPDATE_BEFORE，UPDATE_AFTER两条数据， JDBC connector
>对应的处理会生成两条sql, 一条delete和一条insert.
>
>
>祝好
>Leonard
>[1]https://issues.apache.org/jira/projects/FLINK/issues/FLINK-18461?filter=allissues
>
><https://issues.apache.org/jira/projects/FLINK/issues/FLINK-18461?filter=allissues>
>
