反壓筆記

  定位反壓節點 要解決反壓首先要做的是定位到造成反壓的節點，這主要有兩種辦法 : 1. 通過 Flink Web UI 自帶的反壓監控面板； 2. 通過 Flink Task Metrics。   如果處於反壓狀態，那麼有兩種可能性： １. 該節點的發送速率跟不上它的產生數據速率。這一般會發生在一條輸入多條 輸出的 Operator（比如 flatmap）。 ２. 下游的節點接受速率較慢，通過反

>>阅读原文<<