在 Flink 1.10 版本中,numberOftaskslots 默认值为 1,这意味着每个 TaskManager 只能同时执行一个任务。而 parallelism 是指一个算子并行度的数量,它可以通过 setParallelism() 方法进行设置。如果一个算子的并行度设置为 N,则需要 N 个 TaskManager 才能同时执行该算子的所有实例。

因此,numberOftaskslots 和 parallelism 之间存在一定的关系。如果一个算子的并行度大于 1,那么就需要多个 TaskManager 才能同时执行该算子的实例。如果并行度为 N,而每个 TaskManager 的 numberOftaskslots 只有 1,那么就需要至少 N 个 TaskManager 才能保证该算子的所有实例能够同时执行。否则,一些实例就会被阻塞,无法执行。

总之,numberOftaskslots 和 parallelism 都是影响 Flink 任务并行度的重要参数,需要根据实际情况进行设置。

flink 110版本numberOftaskslots 默认多少和parallelism的关系

原文地址: https://www.cveoy.top/t/topic/eHpJ 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录