このトピックでは、Realtime Compute for Apache Flink のリリースノートについて説明し、関連するリファレンスへのリンクを提供します。リリースノートでは、2023年2月20日にリリースされたバージョンの Realtime Compute for Apache Flink の主要な更新とバグ修正について説明します。
概要
Realtime Compute for Apache Flink の新しい公式バージョンが2023年2月20日にリリースされました。このバージョンは、Apache Flink 1.15.3 の Ververica Runtime (VVR) 6.0.5 をベースに開発されています。 Apache Flink 1.15.3 のすべての不具合はこのバージョンの Realtime Compute for Apache Flink で修正されています。このバージョンでは、StarRocks コネクタが正式にリリースされ、StarRocks データベースのソーステーブルからのデータの読み取りと結果テーブルへのデータの書き込みが容易になります。
機能
機能 | 説明 | 参照 |
Flink Change Data Capture (CDC) コネクタを使用したデータレイクおよびデータウェアハウスへのリアルタイムデータ取り込みにおけるデータ型のマッピング | CREATE DATABASE AS または CREATE TABLE AS ステートメントを使用してデータレイクまたはデータウェアハウスにデータを取り込む場合、データ型に互換性がある場合、アップストリームとダウンストリームのデータストアのテーブルの列のデータ型は異なる場合があります。これは、不要なエラーを防ぐのに役立ちます。このシナリオでは、ダウンストリームデータストアは Hologres のみ可能です。 | |
Flink SQL 複合イベント処理 (CEP) でサポートされているグループパターンまたは NO SKIP パターンの単一要素の複数一致 | Flink SQL CEP は、A(B C)+ に類似したグループパターンと、A B{4,10}? に類似した NO SKIP パターンをサポートしています。 | |
Log Service コネクタを使用した、指定されたコンシューマーグループに保存されているチェックポイントからのバケットとログ消費の設定 | Log Service コネクタを使用すると、64 を超えるシャードを含むログストアのバケット数を指定できます。コネクタは、指定されたコンシューマーグループに保存されているチェックポイントからログを消費することもできます。 | |
StarRocks コネクタ | StarRocks コネクタは、結果テーブルとソーステーブルに使用できます。 | N/A |
CREATE TABLE AS ステートメントの実行中の同期プロセスへの op_ts などのメタデータの追加 | CREATE TABLE AS ステートメントが実行されると、op_ts などのメタデータを同期できます。 |
修正された問題
次の問題が修正されました。デプロイメントで Message Queue for Apache Kafka コネクタの WITH 句のパラメーターを変更した後、デプロイメントが開始に失敗する場合があります。
次の問題が修正されました。Flink CDC が Java Database Connectivity (JDBC) ドライバーを使用して非同期スレッドでデータベースからデータを読み取るときに、メモリ不足 (OOM) エラーの原因が表示されない場合があります。
Codegen のエラーが原因で
Table program cannot be compiled.というエラーメッセージが表示される問題が修正されました。