flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dino Zhang <victordinozh...@gmail.com>
Subject Re: 关于Async I/O的exactly-once
Date Wed, 04 Sep 2019 01:20:24 GMT
hi star,

exactly-once指flink内部的,要保证end-to-end
exactly可以通过两阶段提交,需要实现TwoPhaseCommitSinkFunction,或者做幂等处理

On Wed, Sep 4, 2019 at 8:20 AM star <3149768603@qq.com> wrote:

> 看文档我的理解是会将异步的请求保存在检查点中,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岂不是又要被重新请求一次
>
>
> 谢谢
>
> 发自我的iPhone



-- 
Regards,
DinoZhang
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message