多个复杂算子保证精准一次性

[Colar]

您好，

我有如下代码：

datastream.process(new Process1()).process(new Process2())…

这些Process可能有些复杂的计算操作

请问，如果我要保证端到端的精准一次性，我应该在所有的算子上都维护一个状态还是只在最后一个算子维护状态？