https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/config.html
flink的配置中是有flink taskmanager配置的,一个tm对应几个slots 
。taskmanager.numberOfTaskSlots默认是1.并行度是对应了slots数据,一般我们的slots与并行度最大的一样。你可以看一下这个参数设置。然后对照官网说明。


| |
allanqinjy
|
|
allanqi...@163.com
|
签名由网易邮箱大师定制


在2021年05月7日 16:42,wenyuan138<wenyuan...@gmail.com> 写道:
flink集群(flink 1.10.1),taskmanager有4个,每个有10个slot。 然后我有2个job,
每个并行度是4,预期是会分布到不同taskmanager的slot上(也就是4个taskmanager平均分配2个slot,
这样能更好的利用cpu资源). 结果发现这2个job的8个task全部分配到同一个taskmanager上了。 为什么? 有什么配置可以改变这种行为吗?
我们想要的是task能分到不同的taskmanager上。 谢谢!



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复