apache-flink - Data Stream API 中的 Flink 迭代 - 缺点

Question

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

管理具有大量内存使用的状态 - 从存储中查询

有人可以进一步解释吗？

标签： apache-flinkflink-streaming

Answer 1

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