apache-flink - 流的并行性始终是其生产运算符的并行性

Question

在https://ci.apache.org/projects/flink/flink-docs-release-1.8/concepts/programming-model.html#parallel-dataflows中有描述

算子子任务的数量是该特定算子的并行度。流的并行性始终是其生产运算符的并行性。同一程序的不同运算符可能具有不同级别的并行度。

我不明白什么The parallelism of a stream is always that of its producing operator.意思，有人可以帮忙解释一下吗？谢谢！</p>

标签： apache-flink

Answer 1

这个声明并没有说任何深刻的东西，imo。运算符产生流。运算符有一个或多个并行实例，有时称为子任务，每个实例都在生成流的一部分。