数据流API中的Flink迭代-缺点


0

我们希望将迭代与Async IO操作符结合使用,以便对同一事件执行顺序API调用。然而,在回答我提出的另一个问题时,有人提到用数据流进行迭代是个坏主意。

管理占用大量内存的状态-从存储 query

有人能进一步 explain吗?

1 答案


0

虽然迭代本身目前没有 checkpoints,但是还有其他选项,比如循环展开(如果每个元素有最大的迭代次数)和statefun,它们使用反馈机制来实现与迭代相同的事情,但是以一种对 checkpoints更友好的方式。


我来回答

写文章

提问题

面试题