Flink：跨流状态访问吗？

Question

我有一个流要存储状态，我希望另一个流可以检索状态。这可能吗？

我在我的单元测试中尝试过似乎不起作用。

Answer 1

目前不同的流不可能共享状态。即使属于同一流的不同算子也不能共享状态。

您唯一可以玩的就是使用静态字段在不同的线程之间共享状态，从而也可以在流之间共享状态。但这只有在不同的任务由同一个 TaskManager 执行并因此在同一个 JVM 中运行时才有效。

Answer 2

根据您需要如何使用状态，可以利用queryable state 与另一个流共享它。