Apache Flink是流处理领域的标杆框架，事件时间处理、状态管理与精确一次语义，让实时计算成为可能。
一、Flink的核心特性
Flink以流处理为核心，同时支持批流一体，低延迟与高吞吐兼备，成为实时计算的主流选择。
一）流与批的统一
Flink将批处理视为有界流，同一套API处理批流任务，代码复用与运维成本显著降低。
二）事件时间与窗口
事件时间处理乱序数据，滚动窗口与滑动窗口聚合统计，水位线机制处理迟到数据。
二、状态管理与容错
状态是流处理的关键，Flink管理算子状态与键控状态，检查点机制实现精确一次语义。
一）状态存储与后端
内存状态与RocksDB状态后端各有适用场景，状态TTL管理状态生命周期。
二）检查点与恢复
分布式快照定期保存，故障时从检查点恢复，保证数据不丢不重，Exactly-Once语义。
三、Flink的应用场景
实时数仓、实时风控与实时推荐是Flink的典型应用，数据实时流动创造业务价值。
Flink的学习从流处理概念开始，结合实践项目理解窗口、状态与容错机制，实时计算能力逐步建立。