问具有多个并行性的Flink广播状态

EN

让我把它说出来，我是一个非常初学者的Flink，并试图抓住尽可能多的概念。

比方说，我有一个flink集群，其中包含10个任务管理器。我每个人都有一个flink作业在运行。作业也使用广播状态。该广播状态是通过每10分钟读取5个S3文件，进行一些处理，并创建播放的int to list of strings地图来创建的。

问题:在哪里读取文件，是否在JobManager读取和处理文件，并将处理过的内容发送给任务管理人员。

或

是任务管理人员负责所有的读取和处理。如果是这种情况，那么flink如何确保如果任务管理器无法从S3读取，那么所有任务管理器的广播状态都是相同的。

编辑

因此，任务管理器读取广播流并将其广播到下游任务。

例如：假设有一个卡夫卡流，有5个分区，需要广播。还有一个下游操作符，它的并行性也是5。

1. Partition1使用者任务，从流中读取元素并将其设置为广播状态。一旦设置完毕，状态就会广播到所有下游操作员5 tasks.
2. Partition 2使用者任务，从流中读取元素，并将其设置为广播状态。

问题:在这里，当我们从分区2元素设置广播状态时，我们是否需要确保我们没有覆盖分区1中的元素，或者flink本身来管理它。

或

此外，如何确保分区2消耗元素并设置广播状态时，分区1广播状态已达到分区2下游运算符任务。