Flink，一个插槽可以有多个线程还是只有一个线程？

Question

在Flink中，像“平面地图”、“地图”等运算符称为任务，如果我将平面地图的并行度设置为30，那么这个任务有30个子任务。

现在，如果我只有一个插槽，它会在一个插槽中产生多个线程吗？还是每个插槽只有一个线程？

Flink会在该插槽中简单地创建30个线程，还是使用类似线程池的东西？

以上不是一个恰当的例子。

假设在作业中我有操作符flatMap和map，它们都有并行度1，我只有一个插槽，这个插槽会创建两个线程吗？（链接已禁用）

Answer 1

每个任务槽可以包含多个子任务（运算符）。但是，一个槽不能包含同一个运算符的多个实例——即它可以共享不同的平面图、map等子任务，但不能共享几个相同的maps。链式运算符在同一线程中执行，同时不链式-在不同的线程中。

因此，在您的情况下，如果将平面图的平行性指定为30，flink将需要30个插槽来分配这些子任务。它无法将所有30个子任务分配给单个插槽。

但是，您可以通过taskmanager指定每个任务管理器的插槽数。TaskSlots数量。因此，您可以获取一个只有1个vcore的容器，但可以为其分配30个插槽，从而获得30个单独的线程，并将子任务分配给单个vcore。

请参阅Flink官方留档的任务槽和资源部分。

更新：正如DavidAnderson所指出的，

一个任务槽可能有许多线程。每个子任务都在单独的JVM线程中执行，任务槽基本上是一个线程池。