このトピックでは、Realtime Compute for Apache Flink のリリースノートについて説明し、関連するリファレンスへのリンクを提供します。リリースノートでは、2022 年 12 月 26 日にリリースされたバージョンの Realtime Compute for Apache Flink の主な更新とバグ修正について説明します。
概要
Realtime Compute for Apache Flink の新しいバージョンが 2022 年 12 月 26 日に正式にリリースされました。このバージョンは、Apache Flink 1.15.2 の Ververica Runtime (VVR) 6.0.4 をベースに開発されています。このバージョンでは、Hologres コネクタと MySQL Change Data Capture (CDC) コネクタの複数の機能がサポートされ、動的 Flink 複合イベント処理 (CEP) 機能の機能と使いやすさが最適化されています。
デプロイメントで VVR 6.X を使用している場合は、デプロイメントの安定性を確保するために、できるだけ早く VVR バージョンを VVR 6.0.4 にアップグレードすることをお勧めします。
機能
MySQL CDC コネクタと Postgres SQL CDC コネクタは、Flink CDC V2.3 で提供されるすべての機能をサポートしています。
MySQL CDC コネクタでは、バイナリログデータのコンシューマオフセットを指定できます。
binlog モードの Hologres コネクタは、TIMESTAMP データ型をサポートしています。
Hologres カタログは、ALTER TABLE ステートメントをサポートしています。このステートメントは、Hologres テーブルのプロパティを変更するために使用されます。
Hologres ソーステーブルのコネクタは、フィルタープッシュダウンをサポートしています。これにより、コネクタは Hologres ソーステーブルからすべてのデータを読み取る必要がなくなります。これは、大量のデータが読み取られるシナリオでの読み取りパフォーマンスを最適化します。
動的 Flink CEP では、WITHIN 句を使用してイベント間の時間間隔を指定できます。
動的 Flink CEP では、JSON 形式のルール記述で条件を指定してパラメータを渡すことができます。
動的 Flink CEP の特定の機能が最適化されています。サポートされていない条件が指定された場合に表示されるエラーメッセージが最適化されています。デプロイメントで aviator 条件に基づいて解析されたパターンが無効な場合、エラーは無視され、デプロイメントは失敗しません。
静的 CEP の MATCH_RECOGNIZE 句が強化されました。SHOW TIMEOUT MATCHES、Not Next、Consecutive、Until、Followed By、Followed By Any、Not Followed By などの複数の句がサポートされています。
Message Queue for Apache Kafka ソーステーブルのコネクタを使用して、デプロイメントで指定されたコンシューマグループが既存のコンシューマグループと同じかどうかを確認できます。
Log Service DataStream コネクタがサポートされています。詳細については、Simple Log Serviceコネクタ をご参照ください。
修正された問題
MySQL CDC コネクタがバイナリログデータの消費に失敗した場合に表示されるエラーメッセージが最適化されています。重複するサーバー ID が使用された場合に表示されるエラーメッセージが最適化されています。
SnakeYAML V1.27 の CVE-2022-25857 の脆弱性が修正されました。
NullPointerException (NPE) や配列インデックスの範囲外などの特定の問題に関する実際のエラー情報の説明が、わかりやすくなるように最適化されています。