从保存点恢复时，Flink sink 的行为如何？
How does Flink sink behave when recovering from a savepoint?
想知道 elasticsearch sink connector 从 Flink 上的保存点恢复完成后的行为。
它会 delete/update ES 接收器目标上的文档通过将提交还原到保存点时间点，还是应该使用某种其他机制恢复 ES 索引以便它们再次同步？
我也可以将这个问题推广到其他接收器连接器，例如 Kafka。
Flink可以通过two-phasecommit支持exactly once delivery，end-to-endexactly once delivery也需要连接器保证
Kafka Source和Sink支持exactly once delivery，但是es connector只支持at lease once delivery，es sink从savepoint恢复后，不会有reverting操作
想知道 elasticsearch sink connector 从 Flink 上的保存点恢复完成后的行为。
它会 delete/update ES 接收器目标上的文档通过将提交还原到保存点时间点，还是应该使用某种其他机制恢复 ES 索引以便它们再次同步？
我也可以将这个问题推广到其他接收器连接器，例如 Kafka。
Flink可以通过two-phasecommit支持exactly once delivery，end-to-endexactly once delivery也需要连接器保证
Kafka Source和Sink支持exactly once delivery，但是es connector只支持at lease once delivery，es sink从savepoint恢复后，不会有reverting操作