用途:该技能用于生产级 Flink 架构、运维、SQL/DataStream 实现、升级规划以及湖仓流式集成,适合在用户提到 Flink、Flink SQL、Table API 等场景时使用。
主要能力:覆盖 SQL/Table API、DataStream、部署、运维、升级、CDC 与湖仓 sink/source 等请求分类;提供版本事实与迁移注意事项。
版本事实:当前 Flink 线为 2.2.x,下载包含 Apache Flink 2.2.1,站点仍将 2.2.0 标为最新稳定线;维护中的 2.x 补丁线为 2.2.1、2.1.2、2.0.2;1.x 维护线为 1.20.4,可作为 1.x 迁移基线。Kubernetes Operator 为 1.15.0,兼容 Flink 2.2.x、2.1.x、2.0.x、1.20.x 和 1.19.x。Flink CDC 为 3.6.0,提供面向 Flink 1.20.x 与 2.2.x 的构件。Flink 2.x 要求 Java 11+,新部署实际默认 Java 17。
2.x 关键变化:DataSet API 已移除,改用 DataStream、Table API 或 SQL;核心发行版移除 Scala DataStream/DataSet API;SourceFunction/SinkFunction 与 Sink V1 模式已过时,优先使用 Source/Sink V2 连接器;flink-conf.yaml 被标准 YAML config.yaml 取代;Per-job 部署模式已移除,改用 Application 模式或 Kubernetes Operator 模式;1.x 到 2.x 迁移前需仔细验证 savepoint 兼容性。
使用方式:先分类请求,再针对新项目优先选用 Flink 2.2.x 与当前连接器构件;迁移工作需先确认源版本、连接器版本、状态后端与 savepoint 策略。生产默认建议启用 checkpointing 并设置显式 checkpoint 存储,使用 savepoint 进行计划升级与拓扑变更,谨慎使用 watermark 与 allowed lateness,监控 checkpoint 时长、对齐时间、背压、重启次数与状态大小,Kubernetes 上长期运行的生产作业优先使用 Kubernetes Operator,Iceberg/Paimon/Fluss 连接器仅在所选 Flink 线兼容版本下使用。
限制:资料未提供具体收费、价格、平台或效果信息;实际命令与配置需依据项目锁定版本确认。