??????flink on yarn??????????????????????

Thu, 11 Jun 2020 00:54:16 -0700 

Hi


yarn????????????????????????????????????yarn????????????yarn??????????????


Best,
Yichao Yang




------------------ ???????? ------------------
??????:&nbsp;"[email protected]"<[email protected]&gt;;
????????:&nbsp;2020??6??11??(??????) ????2:32
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;flink on yarn??????????????????????



Hi,
&nbsp;&nbsp;&nbsp; ????????flink??????????????????????????????
&nbsp;&nbsp;&nbsp; 
1.flink????jobmanger??taskmanager????????????????????????????jobmanager????????taskmanager??
&nbsp;&nbsp;&nbsp; 
2.??????jarA??????AbstractYarnClusterDescriptor.deployJobCluster()????flink 
run????????????????jar??????????????????flink??????yarn????????jarB??yarn????jarB??mainClass??????StreamExecutionEnvironment.execute??????????????????java
 -cp 
jarA????????????????????????????????jarA????????????????????jarB??mainClass??????????????yarn??????????????????????????
&nbsp;&nbsp;&nbsp;&nbsp; ??????????????java -cp????????????
&nbsp;&nbsp;&nbsp;&nbsp; ??????????????????????????debug??java -cp????remote 
debug??????flink-conf.yaml??????remote 
debug????????????jarB????mainClass??????????yarn???????????????????? 
&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp; 


[email protected]

回复