Flink 原理與實現：如何處理反壓問題

流處理系統須要能優雅地處理反壓（backpressure）問題。反壓一般產生於這樣的場景：短時負載高峯致使系統接收數據的速率遠高於它處理數據的速率。許多平常問題都會致使反壓，例如，垃圾回收停頓可能會致使流入的數據快速堆積，或者遇到大促或秒殺活動致使流量陡增。反壓若是不能獲得正確的處理，可能會致使資源耗盡甚至系統崩潰。html 目前主流的流處理系統 Storm/JStorm/Spark Stream

>>阅读原文<<