设计上是支持的. 建议贴上代码, 这样大家比较好判断问题所在.
On Fri, Aug 26, 2022 at 4:08 PM 杨扬 <yangya...@cupdata.com> wrote: > 各位好！ > 目前有一flink作业，source与sink均为kafka。 > 在换版时（未修改任何代码）基于官网文档命令，创建savepoint并停止作业；而后基于之前创建的savepoint启动作业。 > 现在发现如此操作无法实现启停前后数据无缝对接，会出现一定的数据重复。 > > 想请教这个问题是savepoint设计时本身就无法保证启停前后端到端一致性，还是我们哪里操作不当呢？ > > > > > > >
