根据需要如何使用状态，可以利用可查询状态与另一个流共享状态。

目前不可能不同的流共享状态。即使属于同一个流的不同操作符也不能共享状态。
唯一可以使用的是使用静态字段在不同的线程和流之间共享状态。但这只有在同一个用户执行不同的任务时才有效 TaskManager 因此，在同一个jvm中运行。