文章 2022-06-12 来自:开发者社区

【Flink】(九)状态一致性、端到端的精确一次(ecactly-once)保证2

4.2 事务写入 (Transactional Writes)需要构建事务来写入外部系统,构建的事务对应着 checkpoint,等到 checkpoint 真正完成的时候,才把所有对应的结果写入 sink 系统中。事务 (Transaction)应用程序中一系列严密的操作,所有操作必须成功完成,否则在每个操作中所作的所有更改都会被撤销具有原子性:一个事务中的一系列的操作要么全部成功,要么一个都....

【Flink】(九)状态一致性、端到端的精确一次(ecactly-once)保证2
文章 2022-06-12 来自:开发者社区

【Flink】(九)状态一致性、端到端的精确一次(ecactly-once)保证1

文章目录一、状态一致性1.1 一致性级别1.2 三个级别的区别二、一致性检查点(Checkpoints)三、端到端(end-to-end)状态一致性四、端到端的精确一次(ecactly-once)保证4.1 幂等写入(Idempotent Writes)4.2 事务写入 (Transactional Writes)4.2.1 预写日志(Write-Ahead-Log,WAL)4.2.2 两阶段提....

【Flink】(九)状态一致性、端到端的精确一次(ecactly-once)保证1

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等