flink-runtime架構

一、flink是什麼? Apache Flink是一個框架和分佈式處理引擎,用於無界和有界數據流上的有狀態計算。Flink被設計成可以在所有常見的集羣環境中運行,以內存中的速度和任何規模執行計算; 二、flink on yarn作業提交流程 1、未引入 Dispatcher 的架構 客戶端提交 JobGraph 以及依賴 jar 包到 YarnResourceManager 接着 Yarn Res
相關文章
相關標籤/搜索