Flink流处理迭代之化解反馈环

咱们都知道Flink在可迭代的流处理中引入了反馈边来将本次迭代的结果反馈给迭代头以进行下一次迭代，这在执行拓扑中引入了环（反馈环）。Flink主要应对的执行拓扑仍是有向无环图（DAG），最终它选择了将反馈环进行化解使其可以适配有向无环图的结构，而如何对反馈环进行化解是咱们这一篇主要探讨的话题。web 任何提交给Flink执行的程序在提交以前都必须先生成做业图，对于用DataStream API编写

>>阅读原文<<