Apache Flink 核心概念

Flink 是面向流处理的分布式引擎，也支持批模式：以事件时间与状态为核心，checkpoint 保证一致性恢复；作业按并行算子拓扑常驻运行。

定位	流批一体引擎，流为主
核心机制	事件时间、状态、checkpoint、反压
部署模式	session 集群、per-job、application 模式

提交 Flink 作业

flink run -d -c com.example.OrdersStreamJob /opt/jobs/orders.jar
flink list
flink cancel <job-id>

Flink 作业本身不负责“按天调度”，常驻流作业与调度平台是互补关系：流做实时，调度跑批与补数。

‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌