文章 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 事务写入 (...

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

基于阿里云Hologres&Flink实时计算平台搭建数据仓库(实时)

23 课时 |
317 人已学 |
免费

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
946 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
512 人已学 |
免费
开发者课程背景图

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注