Re: 回复： flink数据sink到mysql 是事务处理

hi greemqq...@163.com，15701181132mr@gmail.com 能详细介绍一下 幂等 处理的场景吗？ 例如通过upsert语句能做到幂等 hi hdxg1101300...@163.com, 你的sink function的一个statement batch里有insert，delete等语句混合的情况？是用的是flink sql，还是datastream？ Bests, Godfrey Bests, Godfrey Michael Ran 于2020年6月3日周三 下午8:07写道： > 我们也会用幂等处理类似的东西。 >

Re:回复： flink数据sink到mysql 是事务处理

我们也会用幂等处理类似的东西。 1.你要么单条数据处理 2.要么保证每个事务之间不会出现冲突才行，比如楼上说了key by 之类的 在 2020-06-03 15:41:44，"1048262223" <1048262...@qq.com> 写道： >Hi > >可以辛苦贴一下上下文吗，什么场景，mysql的sql是什么。可以先判断是什么导致了MySQL死锁，我理解如果可以对上游做主键keyby，那么下游同时只有一个算子在处理同一个主键。 > > >Best, >Yichao Yang > > > >

回复： flink数据sink到mysql 是事务处理

Hi 可以辛苦贴一下上下文吗，什么场景，mysql的sql是什么。可以先判断是什么导致了MySQL死锁，我理解如果可以对上游做主键keyby，那么下游同时只有一个算子在处理同一个主键。 Best, Yichao Yang --原始邮件-- 发件人:"Px New"<15701181132mr@gmail.com; 发送时间:2020年6月3日(星期三) 中午11:35 收件人:"user-zh"