各位好! 目前有一flink作业,source与sink均为kafka。 在换版时(未修改任何代码)基于官网文档命令,创建savepoint并停止作业;而后基于之前创建的savepoint启动作业。 现在发现如此操作无法实现启停前后数据无缝对接,会出现一定的数据重复。
想请教这个问题是savepoint设计时本身就无法保证启停前后端到端一致性,还是我们哪里操作不当呢?
各位好! 目前有一flink作业,source与sink均为kafka。 在换版时(未修改任何代码)基于官网文档命令,创建savepoint并停止作业;而后基于之前创建的savepoint启动作业。 现在发现如此操作无法实现启停前后数据无缝对接,会出现一定的数据重复。
想请教这个问题是savepoint设计时本身就无法保证启停前后端到端一致性,还是我们哪里操作不当呢?