开发者社区> 问答> 正文

多个复杂算子,如何保证一次性就精准呢?

您好,

我有如下代码:

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

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

请问,如果我要保证端到端的精准一次性,我应该在所有的算子上都维护一个状态还是只在最后一个算子维护状态?*来自志愿者整理的FLINK邮件归档

展开
收起
又出bug了-- 2021-12-03 16:39:15 475 0
1 条回答
写回答
取消 提交回答
  • 你好,中间的状态也不能丢,两个都需要,所有算子都需要维护。*来自志愿者整理的FLINK邮件归档

    2021-12-03 17:44:38
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
FLINK在大规模实时无效广告流量检测中的应用 立即下载
智能设计的增量 立即下载
效率提升:表格存储实时数据流:Stream的技术揭秘和应用场景 立即下载