このトピックでは、Realtime Compute for Apache Flink のリリースノートについて説明し、関連するリファレンスへのリンクを提供します。リリースノートでは、2021 年 8 月 4 日にリリースされたバージョンの Realtime Compute for Apache Flink の主要な更新とバグ修正について説明します。
VVP の主要な更新
ジョブが停止すると、ジョブ用に生成されたすべてのチェックポイントは削除されます。ジョブのステータスを復元する場合は、次のいずれかの方法を使用できます。
ジョブを一時停止してから再開します。
ジョブの停止後に、セーブポイントからジョブを復元します。
新機能
開発機能
SQL ジョブでは、リソースをきめ細かく設定できます。このようにして、共有スロットの CPU コア数とメモリサイズを設定できます。詳細については、「デプロイメントの設定」をご参照ください。
ジョブを公開すると、ジョブの開発バージョンが生成されます。このようにして、バージョン間の比較と履歴バージョンへのロールバックがサポートされます。詳細については、「ジョブバージョンの管理」をご参照ください。
Realtime Compute for Apache Flink の開発コンソールで Hologres カタログを作成できます。このようにして、Realtime Compute for Apache Flink は Hologres カタログを使用して Hologres テーブルに直接アクセスし、Hologres のメタデータを読み取ることができます。詳細については、「Hologres カタログの管理」をご参照ください。
エンジンバージョンの形式が vvr-<Ververica Runtime (VVR) バージョン>-flink-<Flink バージョン> に変更されました。
異なるエンジンバージョンを使用する SQL ジョブを公開できます。 vvr-3.0.3-flink-1.12 バージョンと vvr-4.0.8-flink-1.13 バージョンのみがサポートされています。
重要VVR 3.0.3 以降のバージョンでは、Ververica Platform (VVP) で異なるエンジンバージョンを使用する SQL ジョブを同時に実行できます。VVR 3.0.3 を使用する Flink エンジンのバージョンは Flink 1.12 です。ジョブのエンジンバージョンが 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 に手動で更新してから、ジョブを再起動します。そうしないと、ジョブの開始時にタイムアウトエラーが発生します。
O&M 機能
アラート頻度を設定できます。
Webhook アラートを設定できます。
最適化された機能
JAR パッケージをアップロードする方法が最適化され、アップロード速度が向上しました。
Log Service にダウンロードされたログにジョブ名が追加されました。ジョブ名を使用すると、問題が発生しているジョブを特定できます。
VVR 4.0.8 の主要な更新
Realtime Compute for Apache Flink の開発コンソールで Hologres カタログを作成できます。
リソースをきめ細かく設定できます。
ApsaraDB RDS for MySQL コネクタ用の Java Database Connectivity (JDBC) ドライバのバージョンを更新して、より多くの文字セットと互換性を持たせることができます。
MySQL Change Data Capture (CDC) コネクタは、複数のパラレル スレッドでのフルデータ読み取り、ロックフリー アルゴリズム、および再開可能なアップロードをサポートしています。
AnalyticDB for MySQL V3.0 コネクタは、ON DUPLICATE KEY UPDATE セマンティクスをサポートしています。
VVR 4.0.8 の主要なバグ修正
Kafka テーブルの一部のパーティションにデータがない場合に、currentEmitEventTimeLag メトリックに Log.MAX が表示される問題が修正されました。