このトピックでは、Realtime Compute for Apache Flink のリリースノートについて説明し、関連するリファレンスへのリンクを提供します。リリースノートでは、2022 年 12 月 12 日にリリースされたバージョンの Realtime Compute for Apache Flink の主な更新とバグ修正について説明します。
概要
Realtime Compute for Apache Flink の新しいバージョンが 2022 年 12 月 12 日に正式にリリースされました。このバージョンは、Apache Flink 1.15.2 の Ververica Runtime (VVR) 6.0.3 をベースに開発されています。このバージョンでは、Apache Flink コミュニティの主要な不具合が修正されています。このバージョンでは、ログの情報を選択して、Realtime Compute for Apache Flink の開発コンソールで関連するエラーをクエリできます。
デプロイメントで 6.0.3 より前のバージョンの VVR を使用している場合は、安定した運用を確保するために、できるだけ早く VVR バージョンを 6.0.3 にアップグレードすることをお勧めします。
機能
ログで選択した情報に基づいてエラーをクエリできます。 [イベント] タブと [探索] タブで、エラーに関連するログを見つけて、関連情報を選択してエラーをクエリできます。このようにして、エラーの原因と解決策を入手できます。
CREATE DATABASE AS ステートメントを使用するデプロイメントの NULL 非許容列を作成または削除できます。
Kafka JSON カタログを使用して推論されるスキーマは、JSON メッセージの列シーケンスと一致しています。
MaxCompute へのデータ書き込みの再試行メカニズムを設定できます。このメカニズムは、Tunnel クラスタでサービス中断が発生した場合に、フルマネージド Flink が COMMIT 操作または createUploadSession 操作を実行できないのを防ぐのに役立ちます。
Realtime Compute for Apache Flink は、ApsaraDB RDS データベースでテーブルを作成するための無効な構文と互換性があります。構文が無効な場合、実行中の Flink Change Data Capture (CDC) タスクは影響を受けません。
SQL 構文検証で表示されるエラーメッセージが最適化されました。
バグ修正
次の問題が修正されました。CREATE DATABASE AS ステートメントを実行して Kafka にデータを同期する場合、sink.parallelism パラメータの設定が有効になりません。
VVR 6.0.2 で発生する次の問題が修正されました。CREATE DATABASE AS ステートメントを使用するデプロイメントで ClassCastException エラーメッセージが表示されます。
VVR 6.0.2 で発生する次の問題が修正されました。MySQL CDC ソーステーブルのレイテンシ関連メトリックの曲線グラフが表示されません。
VVR 6.0.2 で発生する次の問題が修正されました。SQL ヒントの構文が有効になりません。
VVR 6.0.2 で発生する次の問題が修正されました。構文チェック中に、クラスの競合がデータ範囲外例外として報告されます。
VVR 6.0.2 で発生する次の問題が修正されました。デプロイメントで CREATE TABLE AS ステートメントを実行して 1 つのテーブルから複数のシンクにデータを書き込むときに、サーバー ID が競合します。
次の問題が修正されました。Kubernetes クラスタのリーダー選出が原因で JobManager のデッドロックが発生します。
状態バックエンドストレージ GeminiStateBackend で発生する「不明なファイルへの参照の減少」エラーが修正されました。