2025-10-13版本 - Realtime Compute for Apache Flink

本文介紹2025年10月13日發布的Realtime ComputeFlink版的重大功能變更和主要缺陷修複。

重要

本次升級計劃在全網分步驟完成灰階，具體升級計劃，請關注Realtime Compute控制台頁面右側的最新公告。如果您不能使用相關新功能，說明您的帳號暫未完成灰階。如果您需要儘快升級，請提交工單告知我們，我們將結合實際情況進行安排。

概述

2025年10月13日正式對外發布Realtime ComputeFlink版新版本。本次更新包含平台升級、引擎更新、連接器更新、效能最佳化以及缺陷修複。

引擎側持續迭代，進一步增強了對複雜資料類型、AI功能以及多種資料來源的支援能力。

Kafka源端：Canal-JSON格式支援MySQL_TYPE解析。

購買體驗提升
- 取消 CU 限制：在擴容、新購及按量轉包年等情境中，取消訂用帳戶叢集超過 1000 CU 的白名單限制，支援大規模作業的彈性擴縮容，提升新購靈活性。
- 優惠券全面支援：在續約、按量轉包年、擴容等情境均可使用優惠券，增強使用者購買靈活性與優惠權益體驗。
可觀測性增強
- 統一 GC 指標展示：新增對 ParallelGC 與 CMS 等記憶體回收類型的指標適配，實現統一監控與管理，提升操作一致性與可觀測性。
- 新增busyTimePerSecond指標：精準反映任務負載情況，助力使用者識別效能瓶頸、合理分配資源，保障作業穩定性。
許可權模型最佳化
打通檔案夾操作許可權與作業草稿、資料查詢許可權，解決因許可權缺失導致無法建立檔案夾的問題，實現許可權體系聯動與操作順暢。
物化表功能改進
編輯物化表時支援同步升級引擎版本，新增版本對比功能，並自動觸發部署作業更新，顯著提升操作便捷性與配置一致性。
訊息投遞靈活配置
支援使用者按需自訂訊息投遞範圍，實現精細化投遞控制，在滿足業務需求的同時有效最佳化投遞成本。

功能名稱	功能描述	參考文檔
Hologres批作業並發寫入	支援reshuffle後並發寫入帶主鍵的Hologres表，提升寫入吞吐。	參數配置（VVR 11及以上版本）
Hologres Binlog消費最佳化	消費Binlog時支援projection下推與資料壓縮，降低網路和計算開銷。
Hologres指定Binlog類型	支援使用者指定讀取的Binlog類型，滿足更精細的資料同步需求。
Kafka Canal-JSON MySQL_TYPE解析	Kafka Source的Canal-JSON格式支援解析MySQL原生類型。	訊息佇列Kafka
JSON String解析為ARRAY<STRING>	支援通過JSON_QUERY函數將JSON String中的數組解析為SQL的ARRAY<STRING>。	JSON Functions
AI Vector Search	新增AI函數，支援向量檢索功能。	VECTOR_SEARCH
MaxCompute時區設定	MaxCompute連接器支援自訂時區，方便跨時區資料處理。	MaxCompute
SLS消費處理器（Processor）	通過`processor`參數在SLS端預過濾資料，降低Flink計算負載。	Log ServiceSLS

本次發布修複了以下主要問題：

修複PostgreSQL CDC讀取數據卡死的問題。
修複Kafka連接器帶有時區屬性的時間戳記轉換丟失時區問題。
修複Lindorm維表Join時null 指標異常。
修改paimon表參數配置錯誤後查看和刪除該表報錯Could not find any factory for identifier 'last_not_null_value' 。