本文介绍 2026 年 7 月 29 日发布的实时计算 Flink 版重大功能变更和主要缺陷修复。
本次升级计划在全网分步骤完成灰度,具体升级计划请关注实时计算控制台页面右侧的最新公告。如遇相关新功能不可用,说明当前账号暂未完成灰度。如需尽快升级,请提交工单反馈,我们将结合实际情况进行安排。
概述
本次发布围绕企业级安全能力补齐、AI 能力对外开放和运维体验提升三大方向展开。平台能力方面,新增 Connector 免密访问和高可用容灾演练,提升企业安全合规水平。OpenAPI 方面,对外开放智能助手对话、自动调优策略管理、技能查询和数据查询等接口,支撑用户将 Flink AI 与数据能力集成到自有平台。体验优化方面,作业运维列表新增多维度筛选能力和重启次数展示,健康分诊断新增重启次数评分规则,将运维从被动响应转向主动预防。
平台能力
高可用容灾演练
高可用项目空间支持发起 AZ 级容灾演练故障模拟,系统自动执行作业节点驱逐与拉起、作业状态恢复,全程实时监控迁移进度,结束后自动生成含 RTO、作业恢复率等核心指标的演练报告。让高可用客户自助完成容灾演练,满足等保/ISO 审计要求,从依赖人工操作升级为控制台一键式、可视化、可审计。
Connector 免密(公测)
新增支持引用 RAM 角色、集成 KMS 凭据管理,优化变量管理入口。OSS Connector 支持通过 RAM 角色访问数据源,PostgreSQL-CDC Connector 支持通过 RAM 角色访问 KMS 凭据。作业配置中无需填写 AccessKey/SecretKey、用户密码,兼容现有显式密钥配置方式。敏感凭证与作业代码解耦,消除明文密钥风险,降低安全审计压力,密钥轮换无需逐作业变更。
体验优化
作业运维体验增强
作业运维列表新增引擎版本筛选、作业类型(SQL/JAR/Python/YAML)筛选、重启次数列展示。解决作业数量增多后筛选能力不足、内部重启异常无感知、批量异常无法按时间定位的问题,将运维从被动响应转向主动预防。
健康分诊断增强
新增重启次数健康分诊断规则:累计重启次数 > 0 评为中等级、> 100 评为高等级、> 300 评为高等级。补齐连续型指标的健康分扣分能力,消除"重启上百次仍 100 分"的感知盲区,让风险可见、评分一致。
OpenAPI
新增智能助手 OpenAPI
开放 AI 智能助手完整生命周期接口,采用异步优先策略,支持会话提交、状态查询、结果获取的异步调用模式,同时提供 SSE 流式接口适配终端用户实时对话场景。新增 1 个接口:
-
发起对话(
ChatAiAgent)
新增自动调优 OpenAPI
开放自动调优(Autopilot)策略管理与调优历史查询接口,支撑用户自建平台批量配置调优策略并追踪调优效果,补齐自动化链路最后一环,避免跳出控制台手工操作。共新增 3 个接口:
-
查询调优策略(
GetAutopilotPolicy) -
更新调优策略(
UpdateAutopilotPolicy) -
查询调优历史(
ListAutopilotTuningHistories)
新增数据查询 OpenAPI
开放 SQL 数据查询脚本的全生命周期管理接口,支持外部系统通过 API 执行 SQL 查询、获取结果、管理脚本文件。共新增 6 个接口,配合已有的 StartSqlExecution 接口形成完整的 SQL 数据查询 API 闭环,支撑在自有平台直接查询 Flink 数据无需登录控制台:
-
停止查询执行(
StopSqlExecution) -
获取查询执行结果(
FetchSqlExecutionResult) -
创建查询脚本(
CreateSqlFile) -
获取查询脚本(
GetSqlFile) -
更新查询脚本(
UpdateSqlFile) -
删除查询脚本(
DeleteSqlFile)