Apache Flink 2.1.0 正式发布，标志着实时数据处理引擎向统一 Data + AI 平台迈进。新版本强化了实时 AI 能力，支持通过 Flink SQL 和 Table API 创建及调用 AI 模型，新增 Model DDL、ML_PREDICT 表值函数等功能，实现端到端的实时 AI 工作流。同时增强了 Flink SQL 的流处理能力，引入 Process Table Functions（PTFs）、Variant 数据类型，优化流式 Join 及状态管理，显著提升作业稳定性与资源利用率。
本文基于Apache Flink PMC成员宋辛童在Community Over Code Asia 2025的演讲，深入解析Flink Agents项目的技术背景、架构设计与应用场景。该项目聚焦事件驱动型AI智能体，结合Flink的实时处理能力，推动AI在工业场景中的工程化落地，涵盖智能运维、直播分析等典型应用，展现其在AI发展第四层次——智能体AI中的重要意义。
