Appearance
Flink 专题
起步入口3 组
专题序列3 个
关联文章9 篇
起步入口先选入口
起步入口先补时间和一致性模型很多窗口和结果正确性问题,本质上都和时间语义、Watermark、Checkpoint 相关。
起步入口再看线上稳定性适合任务延迟升高、反压明显和状态膨胀时继续往下看。
阅读路径按场景进入
入门打底先建立时间语义直觉适合先理解事件时间、处理时间、Watermark 和窗口结果为什么会不一样。
核心原理把状态和 Checkpoint 机制看懂适合理解状态大小、Checkpoint 耗时、恢复一致性和反压之间的关系。
工程实战围绕实时链路稳定性继续落地适合开始做实时看板、实时明细、实时聚合和状态任务调优时继续往下用。
案例排障从延迟升高和反压现象进入适合实时任务已经出现延迟积压、反压明显和恢复耗时长时快速进入。
专题序列Flink 专题本专题共 3 个序列 / 9 篇文章扩容后的文章会继续按序列归档在这里,适合先选一条主线再往下读。
2 篇文章Flink 时间语义与稳定性治理适合把时间语义、Watermark、状态、反压和 Checkpoint 放在一条主线上理解。起步文章:Flink 时间语义、Watermark 和 Checkpoint
- Flink 时间语义、Watermark 和 Checkpoint
- Flink 状态、反压和 Checkpoint 调优
- State Backend 和 Savepoint 怎么理解
- 迟到数据、侧输出流和补数边界
- Exactly Once 和两阶段提交怎么配合
- Checkpoint 对齐与非对齐怎么选
- watermark 乱序容忍度怎么设更合理
- 两阶段提交在 Flink 里怎么落地
延伸相关入口如果你也在做批处理或离线补算,可以继续看 Spark 专题;如果你要把实时链路和离线数仓一起看,也可以继续到 Hive 专题。