Yarn提交Flink任務參數介紹


一、參數介紹

作業模式:yarn-per-job

參數                   描述

-yid                指定任務運行在哪個YarnSession之上

-ynm(Custom Yarnname)      自定義的Yarn名字

-yn (TaskManager)            Flink的TaskManager數目,Flink引擎運行需要由一個JobManager以及若干個TaskManager構成

-ys(Slot)               該參數為單個TaskManager所擁有的槽位數

-yst(Yarnstreaming)         啟動Yarn的流式

-yj(Yarnjar)             Flink的jar包路徑

-yjm(JobManager Memory)               該參數為分配給Jobmanager的堆內存資源,不需要太大

-ytm(TaskManager Memory)            分配給單個TaskManager的堆內存資源

-yq(Yarnquery)           顯示Yarn的資源情況

-yqu                              指定Yarn隊列名

-yz(Yarn Zookeeper Namespace)  在Zookeeper創建一個命名空間             

-yd                  使用Detached模式進行部署,可以運行任務后無需再控制台保持連接

-c                  指定jar包中class全名

 

二、Flink服務器con日志獲取

1、日志路徑

進入對應flink執行節點

/apps/yarn/container-logs/application_1624482781367_19613/container_e34_1624482781367_19613_01_000002

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM