You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by Colar <52...@qq.com> on 2021/04/23 03:22:53 UTC

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

您好，

我有如下代码：

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

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

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

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

Posted by 张锴 <zk...@gmail.com>.

中间的状态也不能丢，两个都需要

hk__lrzy <hk...@163.com> 于2021年4月25日周日 下午8:25写道：

> 所有算子都需要维护。
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>

Posted by hk__lrzy <hk...@163.com>.

所有算子都需要维护。



--
Sent from: http://apache-flink.147419.n8.nabble.com/