本文為您介紹2021年8月4日發布的Realtime ComputeFlink版的重大功能變更和主要缺陷修複。
平台重大功能變更
作業停止後會清理該作業產生的所有Checkpoint,因此如果您需要恢複作業的狀態,可以採取以下任何一種方式:
暫停作業後再恢複作業。
停止後從Savepoint恢複作業。
新增
開發類功能
SQL作業支援配置細粒度資源,即可以配置CPU和記憶體到Share Slot上。詳情請參見配置作業部署資訊。
上線作業時,支援產生開發版本,您可以進行版本比較、復原歷史版本等操作。詳情請參見管理作業版本。
支援Hologres中繼資料,可以通過註冊Hologres Catalog直接存取下遊Hologres表。詳情請參見管理Hologres Catalog。
引擎版本命名格式變更為vvr-<vvr版本號碼>-flink-<flink版本號碼>。
支援提交多個不同引擎版本的SQL作業。目前僅支援vvr-3.0.3-flink-1.12和vvr-4.0.8-flink-1.13兩個版本。
重要從VVR 3.0.3版本(對應Flink 1.12版本)開始,控制台支援同時運行多個不同引擎版本的SQL作業。如果您的作業已使用了Flink 1.12及更早版本的引擎,您需要按照以下情況進行處理:
Flink 1.12版本:停止後啟動作業,系統將自動將引擎升級為vvr-3.0.3-flink-1.12版本。
Flink 1.11或Flink 1.10版本:手動將作業引擎版本升級到vvr-3.0.3-flink-1.12或vvr-4.0.8-flink-1.13版本後重啟作業,否則會在啟動作業時逾時報錯。
營運類功能
支援自訂設定警示頻率。
支援設定Webhook警示。
最佳化
最佳化上傳JAR包的方式,提高上傳速度。
下載到SLS的日誌中新增作業名稱標籤,方便定位作業問題。
VVR 4.0.8版本重大功能變更
支援Holo Catalog。
支援細粒度資源配置。
雲資料庫RDS MySQL連接器 JDBC版本升級,相容更多字元集。
MySQL的CDC 連接器支援多並發讀取全量資料、無鎖演算法和斷點續傳功能。
AnalyticDB for MySQL3.0 連接器支援ON Duplicate Key Update語義。
VVR 4.0.8版本主要缺陷修複
修複Kafka currentEmitEventTimeLag在某些Partition沒有資料時顯示Log.MAX的異常。