关于Async I/O的exactly-once
看文档我的理解是会将异步的请求保存在检查点中，failover的时候重新触发请求。我的问题是既然是重新触发请求，并没有回滚，那之前的请求已经对外部系统造成影响了，不就是at least-once了吗？ 比如ck1:发送了a b c三个请求更新外部数据库，ck2：发送：d，e，f。假设ck1做完了checkpoint，a ，b请求成功，c没成功.
ck2在执行到e的时候任务被cancel了，但c，d都已经成功了。那么我重新启动的时候从最近一次成功的ck1拉起，c，d岂不是又要被重新请求一次*来自志愿者整理的flink邮件归档
展开
收起
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
1
条回答
写回答
-
- 首先你描述的场景，不只存在于 Async IO operator，其他 operator 也会有类似问题
- Flink 的 exactly once 是针对 Flink 内部而言，例如 state 等，[1]
- 如果你想针对外部系统也保证 exactly once 语义，需要对应的 connector 支持 [2]*来自志愿者整理的flink邮件归档
2021-12-08 19:25:27赞同 展开评论
相关问答