Flink背壓原理以及解決優化

由於進行雙11壓測，遇到了Flink的背壓問題。 1.背壓的監控 如果看到任務的背壓警告（如 High 級別），這意味着 生成數據的速度比下游算子消費的的速度快。以一個簡單的 Source -> Sink 作業爲例。如果能看到 Source 有警告，這意味着 Sink 消耗數據的速度比 Source 生成速度慢。Sink 正在向 Source 施加反壓。 許多情況都會導致背壓。例如，GC導致傳入數

>>阅读原文<<