2026-06-03版本 - 实时计算Flink版

本文介绍2026年06月03日发布的实时计算Flink版的重大功能变更和主要缺陷修复。

重要

本次升级计划在全网分步骤完成灰度，具体升级计划，请关注实时计算控制台页面右侧的最新公告。如果您不能使用相关新功能，说明您的账号暂未完成灰度。如果您需要尽快升级，请提交工单告知我们，我们将结合实际情况进行安排。

概述

2026年06月03日正式对外发布实时计算 Flink 版新引擎版本 VVR 11.7（基于 Apache Flink 1.20.3）。本次升级重点增强了安全、AI 实时推理、向量检索、半结构化数据处理和数据摄入能力。引擎侧对 SQL 内置函数调用链路进行了安全加固，并增强 AI Function 对多模态模型、Create Model 参数透传及远程推理服务的支持；同时新增 DLF Paimon 向量表检索能力，优化 Variant、DECIMAL 等复杂类型处理能力。数据摄入方面，Kafka YAML Source、MySQL CDC、SQL Server CDC、Canal JSON、Transform 表达式等能力进一步完善。连接器方面，Elasticsearch、Iceberg、Hologres、MySQL、Kafka 等核心连接器在稳定性、认证能力、连接管理和易用性上持续增强。此外，本版本同步引入 Apache Flink 社区 Async Function、AsyncScalarFunction 相关改进与修复。

引擎侧

持续增强安全、AI 推理、向量检索、类型系统与 API 能力，为实时数据处理、智能分析和湖仓向量检索场景提供更完善的基础支撑。

AI Function 与模型推理

Flink Agents开发支持：支持基于开源Apache Flink Agents框架开发事件驱动的流式 AI Agent 作业。
NVIDIA Triton Inference Server 支持：支持远程调用 NVIDIA Triton Inference Server，扩展在线推理服务的接入方式。
多模态模型调用优化：优化图像与视频理解模型的参数适配能力，提升 AI Function 调用视觉理解类模型时的易用性。
ml_predict 函数增强：支持复用 CREATE MODEL 中的部分模型参数，减少推理 SQL 中的重复配置。

SQL 与类型系统

DECIMAL 精度增强：提升 DECIMAL 类型的精度支持能力，满足高精度数值计算场景（实验性功能）。
Paimon Variant Shredding 支持：提升半结构化数据在 Paimon 中的存储和查询效率。

DataStream/PyFlink API

Python DataStream API 增强：同步 Apache Flink 社区 Async Function 在 Python DataStream API 层面的相关改进。
AsyncScalarFunction 改进：同步 Apache Flink 社区 AsyncScalarFunction 相关修复和能力增强，提升异步标量函数的稳定性与易用性。

安全增强

SQL 内置函数安全加固：修复 SQL 内置函数调用链路中可能存在的代码注入风险，提升作业运行时健壮性。

数据摄入（Flink CDC）

Kafka YAML Source 增强：
- JSON 格式支持容忍 Key 或 Value 中的重复键，提升复杂 JSON 数据接入的兼容性。
- 支持将 Tombstone 消息（Value 为空）转换为 DELETE 事件，便于对接日志压缩 Topic 和删除语义同步场景。
Canal JSON 格式增强：Kafka Canal JSON 数据支持 JSON Converter，提升 Canal JSON 数据解析和类型转换的灵活性。
MySQL CDC 优化：
- 优化字段名称大小写处理逻辑，提升大小写敏感场景下的同步正确性。
- 读取 RDS 归档日志时支持自动查询主库编号，降低归档日志读取场景的配置复杂度。
SQL Server CDC Source：新增 SQL Server 数据源 CDC 能力，支持从 SQL Server 实时捕获变更数据（公测中）。
Transform 表达式增强：优化高精度 DECIMAL 表达式处理，提升数据转换场景的计算正确性。
Hologres YAML Sink：Hologres 支持使用旧版 Put Handler ，提升存量写入链路的兼容性。
Paimon YAML Sink：支持写入通过 blob-descriptor-field 描述符方式存储的 Blob 字段。

连接器

Elasticsearch：新增 connection.keep-alive 参数，支持配置连接保活策略，提升长连接场景下的稳定性。
Kafka：YAML Source 连接器读取 Canal JSON 数据支持 JSON Converter，并增强对重复键和墓碑消息的处理能力。
Paimon：新增vector_search存储过程，支持检索paimon向量表，使用方式详见 support vector search procedure for flink。

缺陷修复

正确性修复：
- 修复 Transform 表达式中 DECIMAL 类型推导精度不足的问题。
- 修复 Flink CDC MySQL 字段名称大小写处理不符合预期的问题。
- 修复 Kafka YAML Source 处理包含重复键 JSON 数据时兼容性不足的问题。
稳定性修复：
- 修复 MySQL BinlogOffset 比较逻辑异常的问题。
- 修复 Paimon DLF 1.0 的 CREATE CATALOG DDL 报错问题。
- 修复 MySQL CDC 出现 Variable character string length must be between 1 and 2147483647 报错的问题。
- 修复 Flink CDC YAML 作业写入 Kafka Debezium JSON 数据时处理默认值报错的问题。