本文為您介紹2023年2月20日發布的Realtime ComputeFlink版的重大功能變更和主要缺陷修複。
概述
2023年2月20日正式對外發布Realtime ComputeFlink版的新版本。本次發布的是基於Apache Flink 1.15.3的VVR 6.0.5版本。該版本包含了Apache Flink 1.15.3全部的缺陷修複。同時,正式發布StarRocks連接器,方便對StarRocks進行結果表寫入和源表讀取。
功能介紹
特性 | 詳情 | 相關文檔 |
Flink CDC 即時資料入湖入倉支援非嚴格的類型對應 | 您在使用CDAS、CTAS文法進行資料入湖入倉時上下遊的列類型可以在相容的情況下不嚴格對應,避免不必要的報錯,目前支援此功能的下遊為Hologres。 | |
Flink SQL CEP支援Group Pattern和NO SKIP的單個元素多次匹配 | 支援類似A(B C)+ 的Group模式和A B{4,10}? 的NO SKIP模式。 | |
SLS連接器支援指定Bucket數量和從指定的消費組中儲存的Checkpoint開始消費日誌 | SLS連接器通過指定Bucket數量對Shard數在64以上的Logstore進行了支援,同時支援了從指定的消費組中儲存的Checkpoint開始消費日誌的選項。 | |
新增StarRocks連接器 | 支援將StarRocks作為結果表和源表進行操作。 | 暫無 |
CTAS方式同步過程加入op_ts等meta資訊 | 在CTAS中,支援同步op_ts等meta資訊的能力。 |
缺陷修複
修複修改作業中Kafka的WITH參數後啟動任務可能導致啟動失敗的缺陷。
修複Flink CDC在非同步線程裡用JDBC讀資料庫時,出現OOM無法透出的缺陷。
修複由於錯誤的codeGen代碼而出現
Table program cannot be compiled.
的問題。