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

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

????????yarn??????????????????????java -cp??????????



[email protected]
 
???????? Yichao Yang
?????????? 2020-06-11 15:53
???????? user-zh
?????? ??????flink on yarn??????????????????????
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]

回复