如何處理 Flink Job BackPressure (反壓)問題?

反壓(BackPressure)機制被廣泛應用到實時流處理系統中,流處理系統需要能優雅地處理反壓問題。反壓通常產生於這樣的場景:短時間的負載高峯導致系統接收數據的速率遠高於它處理數據的速率。許多日常問題都會導致反壓,例如,垃圾回收停頓可能會導致流入的數據快速堆積,或遇到大促、秒殺活動導致流量陡增。反壓如果不能得到正確的處理,可能會導致資源耗盡甚至系統崩潰。 反壓機制就是指系統能夠自己檢測到被阻塞的
相關文章
相關標籤/搜索