Flink Back Pressure(背壓)是怎麼實現的？有什麼絕妙之處？

大數據技術與架構 點擊右側關注，大數據開發領域最強公衆號！ 暴走大數據 點擊右側關注，暴走大數據！ By 暴走大數據 場景描述：如果看到任務的背壓警告（如 High 級別），這意味着 生成數據的速度比下游算子消費的的速度快。以一個簡單的 Source -> Sink 作業爲例。如果能看到 Source 有警告，這意味着 Sink 消耗數據的速度比 Source 生成速度慢。Sink 正在向 Sou

>>阅读原文<<