VIP10
本课程属于：037-Kafka与Flink金融实时数据工程 智能金融与金融工程 · 共 10 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Flink状态容错与在线升级实战

共计 30 章节
可可资料掘金营 · 点击在线试看
01
课程导入
目标=Flink状态容错与在线升级的… · 核心价值 · 整体知识框架与实战路线图
课程导入Flink
02
Flink状态基础
目标=状态类型 · 算子状态与键控状态 · 状态后端
Flink状态基础
03
检查点机制入门
目标=Checkpoint原理 · Barrier对齐 · 精确一次语义
检查点机制入门Checkpoint
04
保存点机制详解
目标=Savepoint原理 · 与Checkpoint区别 · 触发与恢复
保存点机制详解Savepoint
05
状态后端深入
目标=Memory · FsStateBackend · RocksDBStateBacken…
状态后端深入Memory
06
端到端精确一次
目标=Source与Sink的容错语… · 两阶段提交 · 幂等写入与事务性输出实战
端到端精确一次Source
07
故障恢复流程
目标=作业失败类型 · 重启策略 · Region恢复
故障恢复流程目标=作业失败类…
08
状态一致性保障
目标=Exactly-Once与At… · 状态一致性验证 · 数据不丢不重实战
状态一致性保障Exactly-Once
09
大状态管理
目标=状态大小估算 · 状态TTL · 状态清理
大状态管理目标=状态大小估…
10
检查点调优
目标=检查点间隔 · 超时 · 并发
检查点调优目标=检查点间隔
11
Savepoint实战
目标=触发Savepoint · 从Savepoint恢复 · 修改并行度
Savepoint目标=触发
12
在线升级概述
目标=无状态与有状态升级 · 兼容性要求 · 升级流程
线升级概述目标=无状态
13
状态兼容性与演进
目标=状态Schema演进 · 序列化器兼容 · 状态迁移
状态兼容性演进
14
作业重启与升级
目标=全量重启 · 局部重启 · 滚动升级
作业重启升级
15
Flink版本升级
目标=跨版本兼容性 · API变更 · 状态后端迁移
Flink版本升级
16
在线升级中的状态迁移
目标=从旧作业到新作业的状态传递 · Savepoint修改 · 状态处理器API使用
线升级状态迁移
17
状态处理器API实战
目标=读取 · 修改 · 写入Savepoint
API状态处理器
18
Kubernetes与Flink升级
目标=Operator模式 · 原生K8s部署 · 滚动更新
KubernetesFlink
19
YARN与Flink升级
目标=YARN应用模式 · 会话模式 · 升级策略
YARNFlink
20
监控与告警
目标=检查点监控 · 失败告警 · 状态大小监控
监控告警
21
常见故障排查
目标=检查点失败 · Savepoint失败 · 状态恢复异常
常见故障排查目标=检查点失败
22
性能与容错平衡
目标=检查点开销 · 吞吐影响 · 延迟权衡
性能容错平衡
23
案例实战一
目标=电商实时大屏作业状态容错与在线…
案例实战一目标=电商实时大…
24
案例实战二
目标=金融风控作业从Savepoin…
案例实战二Savepoin
25
案例实战三
目标=物联网设备监控作业大状态管理与…
案例实战三目标=物联网设备…
26
案例实战四
目标=跨版本Flink作业在线升级与…
案例实战四Flink
27
综合提升一
目标=设计高可用 · 可升级的Flink有状态作业架构
综合提升一目标=设计高可用
28
综合提升二
目标=制定企业级Flink作业在线升…
综合提升二Flink
29
综合提升三
目标=Flink状态容错与在线升级的…
综合提升三Flink
30
课程总结与展望
目标=核心知识点回顾 · 实战经验总结 · 未来趋势与持续学习路径
课程总结目标=核心知识点…