我们测试环境的flink集群(flink 1.8),taskmanager有3个,每个有10个slot。
然后我有一个job, 其并行度是3,预期是会分布到不同taskmanager的slot上(也就是三个taskmanager各分配一个slot, 这样能更好的利用cpu资源).
结果发现这个job的三个task全部分配到同一个taskmanager上了。
为什么?
有什么配置可以改变这种行为吗?
我们想要的是下图Example 2这样子的, 并行度是2的时候, task能分到不同的taskmanager上。
谢谢!*来自志愿者整理的flink邮件归档
你好, 社区此前已经发现你所遇到的问题了,会在后续版本中修复,目前规划的是在1.7.3, 1.8.2, 1.9.0几个版本中修复。详情可以参考: https://issues.apache.org/jira/browse/FLINK-12122*来自志愿者整理的flink
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。