Flink反压问题

Flink 在运行时主要由 operators 和 streams 两大组件构成。每一个 operator 会消费中间态的流，并在流上进行转换，而后生成新的流。对于 Flink 的网络机制一种形象的类比是，Flink 使用了高效有界的分布式阻塞队列，就像 Java 通用的阻塞队列（BlockingQueue）同样。 在 Flink 中，这些分布式阻塞队列就是这些逻辑流，而队列容量是经过缓冲池来（L

>>阅读原文<<