文章/答案/技术大牛

发布

社区首页 >问答首页 >当从保存点恢复时，Flink接收器的行为如何？

问当从保存点恢复时，Flink接收器的行为如何？
EN

Stack Overflow用户

提问于 2022-01-29 04:39:30

回答 1查看 98关注 0票数 0

想知道当Flink上的保存点的恢复完成时，弹性搜索接收器连接器是如何工作的。

它是通过将提交恢复到保存点时间来删除/更新ES接收器目的地上的文档，还是应该使用其他机制恢复ES索引以使其再次同步？

我也可以将这个问题推广到其他接收器连接器，比如Kafka。

回答已采纳

发布于 2022-01-29 06:55:41

Flink可以通过两阶段提交精确地支持一次传递，而端到端的传递也需要连接器的保证。

Kafka Source和Sink只支持一次传递，但es连接器仅支持至少一次传递，从保存点恢复es接收器后，将不进行恢复操作

票数 1

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/70902332

复制

相似问题

问当从保存点恢复时，Flink接收器的行为如何？EN