Flink反壓問題

Flink 在運行時主要由 operators 和 streams 兩大組件構成。每一個 operator 會消費中間態的流，並在流上進行轉換，而後生成新的流。對於 Flink 的網絡機制一種形象的類比是，Flink 使用了高效有界的分佈式阻塞隊列，就像 Java 通用的阻塞隊列（BlockingQueue）同樣。 在 Flink 中，這些分佈式阻塞隊列就是這些邏輯流，而隊列容量是經過緩衝池來（L

>>阅读原文<<