-1

我刚开始阅读有关 Flink 的内容，想了解更多有关 Flink 如何处理背压以及在存在背压时如何处理故障的信息。我已经阅读了 data-artisans https://data-artisans.com/blog/how-flink-handles-backpressure的这篇博客文章，并且有点理解缓冲池的概念以及它们如何处理背压。

我的问题是

(1) 水印在远程交换的情况下有何帮助（当任务在不同的节点上并且缓冲区被复制到有线 TCP 时）——在上面的博客中阅读。

(2) 系统面临背压时出现故障如何处理？

(3) 只是用于恢复的异步检查点吗？这个检查点包括什么？

(4) 一个检查点捕获了多少缓冲池的数据状态？

4

1 回答 1

1

了解 Flink 网络堆栈当前行为的最佳资源是 Nico Kruber 在 Flink Forward Berlin 2018 上的演讲：使用 Flink 的网络堆栈提高吞吐量和延迟。

至于检查点，Data Streaming Fault Tolerance对它的工作原理以及每个快照中捕获的数据进行了非常全面的解释。

于 2018-11-16T09:28:01.563 回答