反壓(backpressure)是實時計算應用開發中,特別是流式計算中,十分常見的問題。反壓意味著數據管道中某個節點成為瓶頸,處理速率跟不上上游發送數據的速率,而需要對上游進行限速。由于實時計算應用
要解決反壓首先要做的是定位到造成反壓的節點,這主要有兩種辦法:通過 Flink Web UI 自帶的反壓監控面板;通過 Flink Task Metrics。前者比較容易上手,適合簡單分析,后者則提供