Flink进阶（五）：Flink中的反压问题

有段时间没写flink系列文章了，今天写一写Flink中的反压问题。 何为反压？ 在短时间内的负载高峰导致系统接收的数据远大于它能处理数据的速率，如果反压问题不能解决，就会导致系统资源耗尽甚至系统崩溃。那么Flink自身是有反压机制的，它能够自己检测到哪些Operator被阻塞了，然后自适应地降低源头或上游数据的发送速率，从而维持整个系统的稳定。 1.5之前Flink的反压机制 将反压机制之前，先

>>阅读原文<<