了解广播状态是否在Operator的所有示例之间共享。Operator可以是任何东西,但在我的例子中,它是Async I/O Operator。
ny6fqffe1#
处理广播状态的运营商的每个示例接收并潜在地存储该状态的其自己的副本(并且每个示例独立地检查其广播状态)。如果存在广播状态的多个源,则在下游操作器中处理那些广播流的顺序是不确定的,这可能导致各种示例之间的不一致。
1条答案
按热度按时间ny6fqffe1#
处理广播状态的运营商的每个示例接收并潜在地存储该状态的其自己的副本(并且每个示例独立地检查其广播状态)。如果存在广播状态的多个源,则在下游操作器中处理那些广播流的顺序是不确定的,这可能导致各种示例之间的不一致。