flink on yarn使用第一种方式yarn session，先创建一个yarn session，然后再提交job到这个session中。 您的意思是这个session所申请的资源会根据我后续提交的job的并发度去动态地无限地扩展？ 如果我提交了一个并发度为10的job a到这个session，那这个session申请10个slot对应的资源， 我再提交一个并发度为10的job b到这个session，这个session再申请10个slot对应的资源？ job需要多少并发度，session通通都向yarn去申请吗？
-- kingdomad 在 2020-11-11 17:17:16，"hailongwang" <18868816...@163.com> 写道： >根据你 Job 的并发和指定的 TM 的规格来计算出 TM 的数量。 > > >在 2020-11-11 16:14:41，"kingdomad" <kingdo...@163.com> 写道： >>我发现1.11版本的yarn-session.sh废弃了-n参数，那如何指定taskmanager数量？ >> >> >> >> >> >> >> >> >> >> >> >> >> >>-- >> >>kingdomad >>
