Flink源碼解讀系列 | Flink中接收端反壓以及Credit機制

點擊上方藍色字體，選擇「設爲星標」 回覆」資源「獲取更多驚喜 大數據技術與架構 點擊右側關注，大數據開發領域最強公衆號！ 暴走大數據 點擊右側關注，暴走大數據！ 可以看到每個task都會有自己對應的IG(inputgate)對接上游發送過來的數據和RS(resultPatation)對接往下游發送數據, 整個反壓機制通過inputgate,resultPatation公用一個一定大小的memory

>>阅读原文<<