问答 2021-12-07 来自:开发者社区

flink tasks在taskmanager上分布不均衡

我们测试环境的flink集群(flink 1.8),taskmanager有3个,每个有10个slot。 然后我有一个job, 其并行度是3,预期是会分布到不同taskmanager的slot上(也就是三个taskmanager各分配一个slot, 这样能更好的利用cpu资源). 结果发现这个job的三个task全部分配到同一个taskmanager上了。 为什么? 有什么配置可以改变这...

问答 2021-12-02 来自:开发者社区

flink job task在taskmanager上分布不均衡怎么办?

flink集群(flink 1.10.1),taskmanager有4个,每个有10个slot。 然后我有2个job, 每个并行度是4,预期是会分布到不同taskmanager的slot上(也就是4个taskmanager平均分配2个slot, 这样能更好的利用cpu资源). 结果发现这2个job的8个task全部分配到同一个taskmanager上了。 为什么? 有什么配置可以改变这种行为吗?....

问答 2021-01-06 来自:开发者社区

Flink TaskManager JVM 使用的内存是如何分布的

Flink TaskManager JVM 使用的内存是如何分布的

问答 2021-01-06 来自:开发者社区

Flink TaskManager Flink本身使用的内存是如何分布的

Flink TaskManager Flink本身使用的内存是如何分布的

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注
X