Flink:状态是否跨流访问?



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

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

目前,不同的流不可能共享状态。即使是属于同一流的不同运算符也无法共享状态。

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

根据您需要如何使用状态,可以利用可查询状态与其他流共享它。

相关内容

  • 没有找到相关文章