Flink 的網絡協議棧是組成 flink-runtime 模塊的核心組件之一，是每個 Flink 作業的核心。它連接所有 TaskManager 的各個子任務(Subtask)，因此，對于 Flink 作業的性能包括吞吐與延遲都至關重要。與 TaskManager 和 JobManager 之間通過基于 Akka 的 RPC 通信的控制通道不同，TaskManager 之間的網絡協議棧依賴于更加底層的 Netty API。

本文將首先介紹 Flink 暴露給流算子(Stream operator)的高層抽象，然后詳細介紹 Flink 網絡協議棧的物理實現和各種優化、優化的效果以及 Flink 在吞吐量和延遲之間的權衡。

Apache Flink的網絡協議棧詳細介紹

1.邏輯視圖

Flink 的網絡協議棧為彼此通信的子任務提供以下邏輯視圖，例如在 A 通過 keyBy() 操作進行數據 Shuffle ：

這一過程建立在以下三種基本概念的基礎上：

亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb