有没有办法将流分发到 Flink 中每个并行执行的状态？

Question

我有一个迭代流，它的并行度大于 1。我的反馈流包含一些应重新分发到每个并行执行状态的信息。有什么办法吗？

Answer 1

如果您的反馈源是非键控运算符的上游，您可能会专注于广播。

feedbackStream.broadcast();