Flink 异步I/O操作符的所有示例(并行性)是否共享相同的广播状态

aurhwmvo  于 2023-06-04  发布在  Apache
关注(0)|答案(1)|浏览(137)

了解广播状态是否在Operator的所有示例之间共享。
Operator可以是任何东西,但在我的例子中,它是Async I/O Operator。

ny6fqffe

ny6fqffe1#

处理广播状态的运营商的每个示例接收并潜在地存储该状态的其自己的副本(并且每个示例独立地检查其广播状态)。如果存在广播状态的多个源,则在下游操作器中处理那些广播流的顺序是不确定的,这可能导致各种示例之间的不一致。

相关问题