Flink 原理与实现：如何处理反压问题

流处理系统须要能优雅地处理反压（backpressure）问题。反压一般产生于这样的场景：短时负载高峰致使系统接收数据的速率远高于它处理数据的速率。许多平常问题都会致使反压，例如，垃圾回收停顿可能会致使流入的数据快速堆积，或者遇到大促或秒杀活动致使流量陡增。反压若是不能获得正确的处理，可能会致使资源耗尽甚至系统崩溃。html 目前主流的流处理系统 Storm/JStorm/Spark Stream

>>阅读原文<<