Hi,
你的图片丢失了。你可以将图片上传到某个图床,然后将图片链接贴在这里。或者直接粘贴代码。
关于你的问题,flink elasticsearch sink 默认是 at-least-once 保证的,所以及时发生
failover,也能保证数据至少写到 es sink一次,所以理论上不会丢失数据。
不过,如果你手动关闭了 flush on checkpoint,e.g. "connector.flush-on-checkpoint" =
"false", 那么就没有 at-least-once 保证了,数据就可能会丢失。
Best,
Jark
On Sat, 7 Mar 2020 at 15:26, 小旋锋 <
[hidden email]> wrote:
> 大家好:
>
> elasticsearch 不支持事务提交,flink elasticsearch sink无法提供
> exactly-once语义,我发现flink作业意外重启时,会有数据丢失,请问如何让elasticsearch sink不丢失数据呢?
> 注:我的数据每次计算都会得到不同的uuId
>
>
> 感谢
>