Flink初探之 動態限流

前言 最近一段時間,接觸到公司flink代碼,修改時遇到一個flink常見問題,就是上游Producer生產數據的效率大於下游Consumer的消費速度,所以查閱一些大佬的資料,將這一問題記錄,後續系統學習flink的時候複習一下 Flink 流處理爲什麼需要網絡流控? 分析一個簡單的 Flink 流任務,下圖是一個簡單的Flink流任務執行圖:任務首先從 Kafka 中讀取數據、 map 算子對
相關文章
相關標籤/搜索