回复:flink1.9.3 on yarn 提交任务问题

2020-09-09 文章 Jun Zhang
这个应该是和你配置的HA有关,你去掉HA配置试试,或者检查一下HA配置 Best  Jun -- 原始邮件 -- 发件人: 宁吉浩

回复:flink1.9.3 on yarn 提交任务问题

2020-09-09 文章 宁吉浩
link run -m yarn-cluster \ -yn 1 -ys 3 -p 3 -ytm 2048m -ynm test2 \ -c bb.class bbb.jar \ & -- 发件人:zheng faaron 发送时间:2020年9月8日(星期二) 16:09 收件人:user-zh@flink.apache.org 主 题:Re: flink1.9.3 on yarn 提交任务问题 Hi, 第一个问题,per-job的方式和sessi

Re: flink1.9.3 on yarn 提交任务问题

2020-09-08 文章 zheng faaron
Hi, 第一个问题,per-job的方式和session的方式在运行时是不在一个ui中的。 第二个问题,可以配置yarn. container. vcore Best, Faaron Zheng From: 宁吉浩 Sent: Monday, September 7, 2020 3:23:12 PM To: user-zh Subject: flink1.9.3 on yarn 提交任务问题 我选择用 bin/flink run -m yarn cluster 的方式提交任务; 遇到了两个问题: 1. 这两个任

flink1.9.3 on yarn 提交任务问题

2020-09-07 文章 宁吉浩
我选择用 bin/flink run -m yarn cluster 的方式提交任务; 遇到了两个问题: 1. 这两个任务在一个flink集群ui里可见,甚至和之前的flink-session(测试使用)集群在同一个ui里, 这是正常现象吗? 2. 我知道可以通过并行度和slot的指定来确定 tm的数量,查看下图,两个任务一共占用了yarn的8个容器,请问 cpu这个该如何设定? ps: 之前使用spark 可以直接设定 执行器核心数量,现在找不到方法,总不能一个tm8个solt,就使用一个cpu吧