本文介紹2026年06月03日發布的Realtime ComputeFlink版的重大功能變更和主要缺陷修複。
本次升級計劃在全網分步驟完成灰階，具體升級計劃，請關注Realtime Compute控制台頁面右側的最新公告。如果您不能使用相關新功能，說明您的帳號暫未完成灰階。如果您需要儘快升級，請提交工單告知我們，我們將結合實際情況進行安排。
概述
2026年06月03日正式對外發布Realtime Compute 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 CATALOGDDL 報錯問題。修複 MySQL CDC 出現
Variable character string length must be between 1 and 2147483647報錯的問題。修複 Flink CDC YAML 作業寫入 Kafka Debezium JSON 資料時處理預設值報錯的問題。