Flink是如何處理反壓的？

Flink 内部是基于 producer-consumer 模型來進行消息傳遞的，Flink的反壓設計也是基于這個模型。Flink 使用了高效有界的分布式阻塞隊列，就像 Java 通用的阻塞隊列（BlockingQueue）一樣。下遊消費者消費變慢，上遊就會受到阻塞。