You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 孙森 <se...@creditease.cn> on 2020/06/04 01:29:26 UTC
yarn-session多job的模式下是动态申请资源吗
��á���Ŀǰ�õ���flink-1.7.2�汾��ʹ�õ���yarn-session��job��ģʽ������yarn-session֮����flink ui�ϲ�û�п����������õ���Դ�������ύflink job��ʱ��������container�����ύ���jobʱ��yarn-session�ᰴ��job��Ҫ��slot������̬������Դ��
���磬����yarn-session������Ϊ:
./bin/yarn-session.sh -tm 8192 -s 2 �Cn 4
�ύһ��job��Ҫ����Դ�� 8��slot����ôyarn-session������4��taskmanager�����и�job��
���ύһ��job����Ҫ��slot��12������ôyarn-session���������6��taskmanager�����еڶ���job��
���ԣ�������yarn-session�е�-n��û�������ã�������������ɡ�
回复:yarn-session多job的模式下是动态申请资源吗
Posted by star <31...@qq.com>.
-n 没用 1.10就废弃了
------------------ 原始邮件 ------------------
发件人: "孙森"<sensun@creditease.cn>;
发送时间: 2020年6月4日(星期四) 上午9:29
收件人: "user-zh@flink.apache.org"<user-zh@flink.apache.org>;
主题: yarn-session多job的模式下是动态申请资源吗
你好。我目前用的是flink-1.7.2版本,使用的是yarn-session多job的模式。启动yarn-session之后,在flink ui上并没有看到申请配置的资源,而是提交flink job的时候才申请的container。当提交多个job时,yarn-session会按照job需要的slot数量动态申请资源。
比如,启动yarn-session的配置为:
./bin/yarn-session.sh -tm 8192 -s 2 –n 4
提交一个job需要的资源是 8个slot,那么yarn-session会申请4个taskmanager来运行该job。
再提交一个job,需要的slot是12个,那么yarn-session会继续申请6个taskmanager来运行第二个job。
所以,在启动yarn-session中的-n并没有起作用,可以这样理解吧。