flink为 DataSet 批处理提供 checkpoints吗


0

如何为flink批处理配置 checkpoints。我有兴趣知道如何检查指向内部 job 。如果在下一个 checkpoints没有重复,则在下一个 checkpoints重新启动之前,不会有任何重复的检查。flink检查每个操作员、 sink和信号源的点吗?

1 答案


0

Flink不支持 DataSet API上的 checkpoints。

但是,您可以在数据流中对有限的源使用 checkpoints,这已经涵盖了大多数DataSet API用例。长远的设想是用DataStream+有限源完全替换DataSet API,这样用户如果想分析流或批处理,就不需要编写两个程序。

对于表API和SQL,这个目标已经很接近了。


我来回答

写文章

提问题

面试题