Flink進階(五):Flink中的反壓問題

有段時間沒寫flink系列文章了,今天寫一寫Flink中的反壓問題。 何爲反壓? 在短時間內的負載高峯導致系統接收的數據遠大於它能處理數據的速率,如果反壓問題不能解決,就會導致系統資源耗盡甚至系統崩潰。那麼Flink自身是有反壓機制的,它能夠自己檢測到哪些Operator被阻塞了,然後自適應地降低源頭或上游數據的發送速率,從而維持整個系統的穩定。 1.5之前Flink的反壓機制 將反壓機制之前,先
相關文章
相關標籤/搜索