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

Question

我们希望将迭代与异步 IO 运算符结合使用，以对同一事件执行顺序 API 调用。但是，在回答我提出的另一个问题时，有人提到使用数据流进行迭代是一个坏主意。

有人可以进一步解释吗？

Answer 1

虽然迭代本身目前没有检查点，但还有其他选项，如循环展开（如果每个元素有最大迭代次数）和 statefun，它使用反馈机制来实现相同的目的迭代所做的事情，但以一种更加检查点友好的方式。