我的做法是，在MysqlSink中，使用replace into，然后根据数据会根据唯一键，自己考虑新增还是更新。
希望能对你有点价值吧 > 在 2019年3月25日，下午3:58，[email protected] 写道： > > 大家好！ > > 可爱的flink贡献者，能不能增加个JDBC Sink > 更新策略接口？目前只有增量插入，实际中对更新需求还是非常普遍的，目前要想支持更新，只能自己修改源码增加，这样感觉不是很友好。棒棒的贡献者，期待JDBC > Sink 更新策略接口的出现。 > > 基于flink工作的伙伴们，如果有谁实现了JDBC Sink 更新策略接口，希望能分享下代码，感谢！ > > > > [email protected]
