本文介紹在單作業模式下Flink提交作業的具體流程,如下圖所示。
- 客戶端將作業提交給YARN的RM;
- YARN的RM啟動Flink JobManager,并將作業提交給JobMaster;
- JobMaster向Flink內置的RM請求slots;
- Flink內置的RM向YARN RM請求容器;
- YARN 啟動帶有TaskManager的容器;
- TaskManager啟動之后,向Flink的RM注冊自己的可用slots;
- Flink的RM通知TaskManager為作業提供slots;
- TaskManager連接到對應的JobMaster,并提供slots;
- JobMaster將需要執行的作業分發給TaskManager執行。