Flink 新一代流计算和容错问题之在有状态的算子中,状态更新是怎么记录的

本文涉及的产品
实时计算 Flink 版,5000CU*H 3个月
简介: Flink 新一代流计算和容错问题之在有状态的算子中,状态更新是怎么记录的

问题一:Buffer Debloating 如何帮助 Unaligned Checkpoint?


Buffer Debloating 如何帮助 Unaligned Checkpoint?


参考回答:

Buffer Debloating 通过减少中间流动的数据量,使得 Unaligned Checkpoint 在做快照时需要额外存储的中间数据也变少,从而加快 Checkpoint 的完成速度。


关于本问题的更多回答可点击原文查看:

https://developer.aliyun.com/ask/671169



问题二:在 Buffer Debloating 中,Debloat Target 指的是什么?


在 Buffer Debloating 中,Debloat Target 指的是什么?


参考回答:

在 Buffer Debloating 中,Debloat Target 是指上游缓存“预期时间”内下游能处理的数据量。这个设置帮助动态调整缓存大小。


关于本问题的更多回答可点击原文查看:

https://developer.aliyun.com/ask/671170



问题三:Generalized Log-Based Incremental Checkpoint 的主要目的是什么?


Generalized Log-Based Incremental Checkpoint 的主要目的是什么?


参考回答:

Generalized Log-Based Incremental Checkpoint 的主要目的是控制每次快照时需要上传的数据量,通过将 Checkpointing 过程和 State Backend 存储 Compaction 剥离开来,使得 Checkpoint 变得更加稳定和高频,从而缩短端到端的延迟。


关于本问题的更多回答可点击原文查看:

https://developer.aliyun.com/ask/671171



问题四:在有状态的算子中,状态更新是如何记录的?


在有状态的算子中,状态更新是如何记录的?


参考回答:

在有状态的算子中,状态更新会记录在 State Table 里。当 Checkpointing 发生时,这个 State Table 会被刷到磁盘上,并异步上传到远端存储。


关于本问题的更多回答可点击原文查看:

https://developer.aliyun.com/ask/671172



问题五:为什么 RocksDB 的增量 Checkpoint 有时并不比完整 Checkpoint 更高效?


为什么 RocksDB 的增量 Checkpoint 有时并不比完整 Checkpoint 更高效?


参考回答:

虽然 RocksDB 支持增量 Checkpoint,但一旦触发多层 Compaction,就会生成很多新的文件,这可能导致增量的部分甚至比一个完整的 Checkpoint 更大,因此上传时间依然不可控。


关于本问题的更多回答可点击原文查看:

https://developer.aliyun.com/ask/671173

相关实践学习
基于Hologres轻松玩转一站式实时仓库
本场景介绍如何利用阿里云MaxCompute、实时计算Flink和交互式分析服务Hologres开发离线、实时数据融合分析的数据大屏应用。
Linux入门到精通
本套课程是从入门开始的Linux学习课程,适合初学者阅读。由浅入深案例丰富,通俗易懂。主要涉及基础的系统操作以及工作中常用的各种服务软件的应用、部署和优化。即使是零基础的学员,只要能够坚持把所有章节都学完,也一定会受益匪浅。
相关文章
|
3月前
|
消息中间件 存储 NoSQL
Flink(十二)【容错机制】(4)
Flink(十二)【容错机制】
|
3月前
|
存储 缓存 算法
Flink(十二)【容错机制】(2)
Flink(十二)【容错机制】
|
23天前
|
调度 流计算
Flink 新一代流计算和容错问题之Flink 中的数据可以分为什么类型
Flink 新一代流计算和容错问题之Flink 中的数据可以分为什么类型
|
23天前
|
Cloud Native 安全 调度
Flink 新一代流计算和容错问题之Flink 通过云原生技术改进容错设计要如何操作
Flink 新一代流计算和容错问题之Flink 通过云原生技术改进容错设计要如何操作
|
23天前
|
运维 Cloud Native 数据库
Flink 新一代流计算和容错问题之将 Flink 的容错与云原生的弹性扩缩容相结合要怎么操作
Flink 新一代流计算和容错问题之将 Flink 的容错与云原生的弹性扩缩容相结合要怎么操作
|
23天前
|
存储 流计算
Flink 新一代流计算和容错问题之Flink 通过 Key Group 管理状态是怎么操作的
Flink 新一代流计算和容错问题之Flink 通过 Key Group 管理状态是怎么操作的
|
23天前
|
存储 调度 流计算
Flink 新一代流计算和容错问题之如何实现 Generalized Log-Based Incremental Checkpoint
Flink 新一代流计算和容错问题之如何实现 Generalized Log-Based Incremental Checkpoint
|
23天前
|
缓存 流计算
Flink 新一代流计算和容错问题之 Flink 作业的 local buffer pool 的 size 要如何估算
Flink 新一代流计算和容错问题之 Flink 作业的 local buffer pool 的 size 要如何估算
|
23天前
|
存储 缓存 数据处理
Flink 新一代流计算和容错问题之中间数据流动缓慢导致 Checkpoint 慢的问题要如何解决
Flink 新一代流计算和容错问题之中间数据流动缓慢导致 Checkpoint 慢的问题要如何解决
|
3月前
|
存储 消息中间件 算法