?????? ???? yarn-session.sh??????????????????????????????

[MuChen]

hi,Yang Wang:


HDFS????staging????($HOME/.flink/application_id)??*flink-conf.yaml*??????????????????????????-qu??-nm??????-jm??-tm????????????????????????????????????


??????-n??????????????????????????????????????????????????????????????-n????????????????????????????


??????????????


Best,
MuChen


------------------ ???????? ------------------
??????:&nbsp;"Yang Wang"<danrtsey...@gmail.com&gt;;
????????:&nbsp;2020??6??22??(??????) ????8:37
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;Re: ???? yarn-session.sh??????????????????????????????



????????????HDFS????staging????($HOME/.flink/application_id)??????client????????*flink-conf.yaml*
??????????"yarn.application.queue"??"yarn.application.name"????????????????


??????-n????????????????????????????????????????????????????????TM??


Best,
Yang

MuChen <9329...@qq.com&gt; ??2020??6??22?????? ????7:32??????

&gt; hi,all:
&gt;
&gt;
&gt; ????????hadoop??????????????A.
&gt;
&gt;
&gt; ????????A????????bin/yarn-session.sh -n 5 -jm 1g -tm 4g -s 4 -qu 
root.flink -nm
&gt; fsql-cli &amp;gt; /dev/null 2&amp;gt;&amp;amp;1 
&amp;amp;????????????????yarn-session??
&gt; ????????????????root.flink????????fsql-cli.
&gt;
&gt;
&gt; 
????????yarn????????????????????????????????????????????????????????????????????????????????????????
&gt; https://imgchr.com/i/NJIn4x
&gt;
&gt;
&gt; ??????????Flink session cluster
&gt; ??????????root.default
&gt;
&gt;
&gt; ??????????????????????????????????????????
&gt;
&gt;
&gt; flink??????1.10.0
&gt; flink-conf.yaml??????
&gt; [fsql@10-42-63-116 conf]$ grep -v ^# flink-conf.yaml |grep -v ^$
&gt; jobmanager.rpc.address: localhost
&gt; jobmanager.rpc.port: 6123
&gt; jobmanager.heap.size: 1024m
&gt; taskmanager.memory.process.size: 2048m
&gt; taskmanager.numberOfTaskSlots: 10
&gt; parallelism.default: 1
&gt; jobmanager.execution.failover-strategy: region