开发者社区 问答 正文

请问,如果我要保证端到端的精准一次性?

您好, 我有如下代码: datastream.process(new Process1()).process(new Process2())… 这些Process可能有些复杂的计算操作 请问,如果我要保证端到端的精准一次性,我应该在所有的算子上都维护一个状态还是只在最后一个算子维护状态?*来自志愿者整理的flink

展开
收起
毛毛虫雨 2021-12-05 11:39:12 415 分享 版权
1 条回答
写回答
取消 提交回答
  • 所有算子都需要维护,中间的状态也不能丢,两个都需要。*来自志愿者整理的flink

    2021-12-06 11:38:23
    赞同 展开评论
问答地址: