全部產品
Search
文件中心

Realtime Compute for Apache Flink:2025-11-30版本

更新時間:Dec 18, 2025

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

重要

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

概述

2025年11月30日正式對外發布Realtime ComputeFlink版新引擎版本VVR 11.4.0。本次升級聚焦增強引擎核心與生態系統的串連能力,全面強化 Flink CDC、Paimon、AI 整合及主流資料來源連接器的功能與穩定性,並首次引入新的資料來源 Catalog 支援。同時,平台核心能力與使用者體驗也得到顯著提升。主要功能如下:

引擎側

引擎側持續迭代,進一步增強了流批一體處理、Data Integration、AI功能以及多種資料來源的支援能力。

AI功能

新增 7 個AI函數用於 Flink SQL 文本處理:

  • AI_CLASSIFY(文本分類):根據預設類別對文本分類。返回信賴度分數。適用於工單歸類和內容打標。

  • AI_SENTIMENT(情感分析):分析文本情感。返回量化分數及正向、負向或中性標籤。適用於評論分析和輿情監控。

  • AI_EXTRACT(資訊提取):使用 JSON Schema 從非結構化文本中提取資料(如姓名、電話)。輸出結構化資料。

  • AI_SUMMARIZE(摘要產生):產生長文本摘要。支援設定最大長度。

  • AI_EMBED(向量化):將文本轉換為高維向量。用於計算相似性和語義檢索。

  • AI_TRANSLATE(文本翻譯):在 10 餘種語言間互譯。自動檢測源語言。

  • AI_MASK(資料脫敏):自動屏蔽電話、社會安全號碼等敏感資訊。

資料攝入

連接器

  • Kafka

    • Canal-JSON 格式支援解析源庫索引事件。支援提取原始 Key 和 Value 作為中繼資料。

    • 資料處理升級,支援Protocol Buffers v3 (Proto3) 協議標準。

  • Hologres

    • 維表關聯支援過濾條件下推。

    • Stream Copy 模式支援 BinaryRow 格式。

    • INSERT 操作支援配置主鍵衝突處理邏輯。

  • JDBC(PostgreSQL):新增ignore delete選項, 忽略源表刪除事件。

  • Paimon

    • 支援跨分區更新。

    • 支援設定使用者名稱首碼,方便定位作業。

  • Redis:增強叢集模式支援。支援批處理寫入。

Catalog

平台側

核心功能

  1. 專案空間複製:將專案空間複製到其他工作空間。適用於叢集遷移或雙跑測試。

  2. 切換監控服務:支援控制台手動切換 Flink 監控類型。

  3. 許可權管理

    • 支援配置“禁用”許可權點。

    • 支援設定 Git 整合的細粒度許可權。

  4. 日誌歸檔:使用 RAM 授權將日誌歸檔至 SLS。此方式替代 Access Key,增強安全性。

體驗改進

  • 營運展示:在營運頁面顯示動態更新與自動調優的狀態及結果。

  • 計費標籤:自動標籤混合計費的彈性資源,便於分賬。

  • 資源搜尋:支援按工作空間、訂單一實例 ID 或專案空間搜尋資源。

主要缺陷修複

本次發布修複了社區版本中的已知問題,並針對以下主要問題進行了重點改進:

  • Kafka 連接器:修複因事務堆積導致的任務掛起。

  • Prometheus Metric Reporter:修複因未關閉網路連接導致的記憶體溢出。

  • MySQL CDC:修複無法讀取 OSS Binlog 歸檔日誌的問題。

  • 混合計費:已修複開通流程中,訂單作廢后,再次開通報錯的問題。

  • 專案空間:已經禁止刪除最後一個專案空間,避免無法登入開發控制台。