我有一个流将要存储状态，我希望另一个流可以检索状态。这可能吗？我在单元测试中尝试过，但似乎不起作用。
llmtgqce1#
根据需要如何使用状态，可以利用可查询状态与另一个流共享状态。
siotufzp2#
目前不可能不同的流共享状态。即使属于同一个流的不同操作符也不能共享状态。唯一可以使用的是使用静态字段在不同的线程和流之间共享状态。但这只有在同一个用户执行不同的任务时才有效 TaskManager 因此，在同一个jvm中运行。
TaskManager
2条答案
按热度按时间llmtgqce1#
根据需要如何使用状态，可以利用可查询状态与另一个流共享状态。
siotufzp2#
目前不可能不同的流共享状态。即使属于同一个流的不同操作符也不能共享状态。
唯一可以使用的是使用静态字段在不同的线程和流之间共享状态。但这只有在同一个用户执行不同的任务时才有效
TaskManager因此，在同一个jvm中运行。