pyflink 请教能否将不同子任务的中间计算值进行聚合？

[Huilin_WU]

现在我有一个流，分成三个subtasks，三个subtasks的计算的中间结果（后续需要进行别的操作）比如分别是13，14，15，请问如何可以把三个子任务的中间计算结果进行聚合（比如相加）? 意思就是说，将所有子任务的中间结果进行聚合，但是同时线程仍然在运行下一步的任务。

请问应该如何操作？