本リリースは、Apache Flink 1.15.2 を基盤とする Ververica Runtime (VVR) 6.0.3 に基づきます。Apache Flink コミュニティから報告された主要な不具合を修正し、プラットフォームの機能強化およびコネクタの更新を実施しています。
ご利用のデプロイメントが VVR 6.0.3 より前のバージョンで動作している場合、安定した本番運用を確保するため、できる限り早期に VVR 6.0.3 へアップグレードしてください。
新機能
プラットフォーム
ログ選択からの直接エラークエリ
Realtime Compute for Apache Flink 開発コンソールの **[イベント]** タブおよび **[探索]** タブにおいて、ログエントリ内のテキストを選択することで、関連するエラーをクエリできます。結果にはエラーの原因と推奨されるソリューションが表示されるため、コンソールを離れることなくトラブルシューティングが可能です。
SQL 構文エラーメッセージの最適化
SQL 構文検証時に返されるエラーメッセージが明確化され、無効な構文の特定および修正が迅速に行えるようになりました。
コネクタおよびカタログ
MaxCompute への書き込みに対するリトライ機構の設定
Tunnel クラスターでサービス中断が発生した場合でも、COMMIT 操作または createUploadSession 操作の失敗を防止するため、MaxCompute へのデータ書き込みに対してリトライポリシーを設定できます。これにより、手動介入なしで書き込みジョブの耐障害性が確保されます。
CREATE DATABASE AS デプロイメントにおける非 NULL 列の作成および削除
CREATE DATABASE AS 文を使用するデプロイメントでは、非 NULL 列の作成および削除がサポートされるようになりました。
Kafka JSON カタログのスキーマと JSON メッセージの列順序の整合
Kafka JSON カタログによって推論されたスキーマが、ソース JSON メッセージ内の列シーケンスと一致するようになりました。これにより、列の並び替えによるスキーマ不整合が解消されます。
ApsaraDB RDS における無効なテーブル作成構文への対応
Realtime Compute for Apache Flink は、ApsaraDB RDS データベースにおける無効なテーブル作成構文に対して互換性を持つようになりました。無効な構文が検出された場合でも、Change Data Capture (CDC) タスクの実行が中断されることはありません。
不具合修正
sink.parallelism 設定が Kafka 同期向け CREATE DATABASE AS で無視される問題
sink.parallelism パラメーターが、CREATE DATABASE AS を用いた Kafka へのデータ同期時に正しく適用されるようになりました。
CREATE DATABASE AS デプロイメントにおける ClassCastException 発生（VVR 6.0.2）
CREATE DATABASE AS を使用するデプロイメントで、ClassCastException エラーが発生しなくなりました。
MySQL CDC ソーステーブルの遅延メトリックチャートが表示されない問題（VVR 6.0.2）
MySQL CDC ソーステーブルの遅延関連メトリックの折れ線チャートが、正しくレンダリングされるようになりました。
SQL ヒント構文が適用されない問題（VVR 6.0.2）
クエリ実行時に、SQL ヒントが期待通りに効果を発揮するようになりました。
構文チェック時のクラス競合が「データ範囲外」例外として誤って報告される問題（VVR 6.0.2）
構文チェック中に発生するクラス競合が、「データ範囲外」例外ではなく、正確な形で報告されるようになりました。
CREATE TABLE AS による単一テーブルから複数 sink への書き込み時におけるサーバー ID 衝突（VVR 6.0.2）
CREATE TABLE AS デプロイメントで、単一テーブルから複数の sink へデータを書き込む際に、サーバー ID の衝突が発生しなくなりました。
Kubernetes クラスターにおけるリーダー選出時の JobManager デッドロック
Kubernetes クラスターにおけるリーダー選出時に、JobManager がデッドロックを起こさなくなりました。
GeminiStateBackend における「未知のファイルへの参照を減らす」エラー
GeminiStateBackend 状態バックエンドが、「Decrease reference to an unknown file」エラーを出力しなくなりました。