Apache Flink 以有状态流处理为核心,也支持有界数据的批式执行。事件时间、水位线、状态后端、checkpoint 和 exactly-once 语义使它适合实时计算、复杂事件处理和持续数据管道。

官方文档按版本维护,DataStream、Table/SQL、连接器和部署章节需要对应实际集群版本。升级时状态兼容、savepoint、序列化和连接器依赖比代码能否编译更关键。

学习可从本地示例理解事件时间和状态,再进入 Kafka、文件或数据库连接。生产部署还要规划容错、反压、资源和监控,不能把示例配置直接照搬。