小编Qeh*_*ehu的帖子

Flink 插槽/并行度与最大 CPU 能力

我试图理解 .yaml 文档中 flink 插槽和并行配置背后的逻辑。

Flink 官方文档指出,对于 cpu 中的每个核心,您必须分配 1 个插槽,同时将并行度提高 1 个。

但我认为这只是一个建议。例如,如果我有一个强大的核心(例如具有最大 GHz 的最新 i7),那么它与具有有限 GHz 的旧 CPU 不同。因此,运行比我的系统 CPU 最大核心数更多的插槽和并行度并不是不合理的。

但是,除了测试不同的配置之外,还有其他方法来检查我的系统使用 flink 的最大功能吗?

仅供记录,我使用 Flink 的 Batch Python API。

python parallel-processing apache-flink

2
推荐指数
1
解决办法
2230
查看次数

标签 统计

apache-flink ×1

parallel-processing ×1

python ×1