假设我有8个任务管理器和16个任务槽。如果我使用jobmanager ui提交作业并将并行度设置为8，那么我是否只使用8个任务槽？如果我有8个具有8个槽位的任务管理器，并且以8个并行度提交同一个作业，会怎么样？完全一样吗？或者数据的处理方式有差异吗？谢谢您。
krcsximq1#
flink集群中任务槽的总数定义了最大并行度，但使用的槽数可能超过实际并行度。例如，考虑以下工作：如果在具有2个任务管理器的集群中以2个并行运行，每个任务管理器提供3个插槽，则调度程序将使用5个任务插槽，如下所示：但是，如果基本并行度增加到6，那么调度程序将执行此操作（请注意，在本例中，接收器的并行度保持为1）：有关更多信息，请参阅flink的分布式运行时环境。
1条答案
按热度按时间krcsximq1#
flink集群中任务槽的总数定义了最大并行度，但使用的槽数可能超过实际并行度。例如，考虑以下工作：
如果在具有2个任务管理器的集群中以2个并行运行，每个任务管理器提供3个插槽，则调度程序将使用5个任务插槽，如下所示：
但是，如果基本并行度增加到6，那么调度程序将执行此操作（请注意，在本例中，接收器的并行度保持为1）：
有关更多信息，请参阅flink的分布式运行时环境。