Re: 触发savepoint后, source算子会从对应offset处停止消费吗?

hi, 在我的理解里，savePoint 的作用和 checkPoint 是类似的，只是在 flink 1.16 以前 savePoint 只支持全量的 savePoint，底层都是采用的 barrier 实现机制。但是在1.16的规划文档里（ https://cwiki.apache.org/confluence/display/FLINK/FLIP-203%3A+Incremental+savepoints），savepoint 也将支持增量的模式。 当 savepoint 触发时， source 会去保存状态，是会停止消费的。 郑 致远 于2022年9月8日周四 19:39写道：

触发savepoint后, source算子会从对应offset处停止消费吗?

各位大神好. 请教 savepoint 也是用 barrier机制实现的吗? savepoint 触发的时候, source算子会停止从kafka消费吗?