Realtime Compute for Apache Flink では、新機能の追加、パフォーマンス向上、バグ修正を含む新しいエンジンバージョンがリリースされます。これらの改善を活用するには、デプロイメントのエンジンバージョンをアップグレードしてください。本トピックでは、アップグレード手順、バージョン互換性ルール、およびロールバック方法について説明します。
事前準備
アップグレードを実行する前に、以下の互換性ルールおよび準備手順をご確認ください。
バージョン互換性
原則として、同一メジャーバージョン内のマイナーバージョン同士は互換があります。アップグレード前に生成されたチェックポイントおよびセーブポイントは、引き続き使用可能です。
| アップグレード種別 | 例 | 状態の互換性 |
|---|---|---|
| マイナーバージョン | vvr-4.0.15-flink-1.13 から vvr-4.0.18-flink-1.13 | 互換性あり |
| メジャーバージョン | vvr-4.0.15-flink-1.13 から vvr-6.0.2-flink-1.15 | 保証されません。状態データなしで再起動が必要です。 |
バージョン番号の仕様については、「エンジンバージョン」の「エンジンバージョンおよびバージョン番号各桁の意味」セクションをご参照ください。上流互換性マトリックスについては、「アプリケーションおよび Flink バージョンのアップグレード」の「互換性テーブル」をご参照ください。
セーブポイントフォーマットの選択（Ververica Runtime 6.X 以降）
Ververica Runtime（VVR）6.X 以降を採用した Realtime Compute for Apache Flink では、2 種類のセーブポイントフォーマットがサポートされています。
| フォーマット | 利点 | 推奨用途 |
|---|---|---|
| ネイティブフォーマット | セーブポイント生成が高速 | マイナーバージョンアップグレード（同一メジャーバージョン内） |
| 標準フォーマット | クロスバージョン互換性に優れる | メジャーバージョンアップグレード |
新しいエンジンバージョンでは、古いバージョンで生成されたセーブポイントを読み取ることができます。ただし、その逆（古いエンジンバージョンで新しいバージョンのセーブポイントを読み取ること）は保証されません。古いエンジンバージョンでは、新しいバージョンで生成されたセーブポイントを読み取れない場合があります。
依存関係バージョンの整合性
SQL デプロイメントまたは DataStream デプロイメントにおける Realtime Compute for Apache Flink の依存関係バージョンは、デプロイメントで選択した Realtime Compute for Apache Flink のバージョンと一致させる必要があります。
BlinkPlanner の互換性（Apache Flink 1.13.0 以降）
Apache Flink 1.13.0 以降では、BlinkPlanner がデフォルトの SQL Planner として採用されています。BlinkPlanner は、Alibaba Group により Apache Flink コミュニティに寄贈されたものです。Apache Flink 1.13.0 より前のバージョンから、Apache Flink 1.13.0 を基盤とする VVR 4.0 以降へ移行する場合、一部の構文および API が互換性を持たない可能性があります。詳細については、「Apache Flink 1.13.0 リリースアナウンス」をご参照ください。
操作手順
アップグレードは「クローン＋切り替え」方式で実行します。既存のドラフトまたはデプロイメントをクローンし、クローン先を対象エンジンバージョンにアップグレードした後、正しく動作することを検証し、元のデプロイメントを廃止します。この方式により、元のデプロイメントをロールバック用にそのまま維持できます。
ステップ 1：ドラフトのクローン作成と対象エンジンバージョンの設定
安定版または推奨版のエンジンバージョンを選択してください。これらのバージョンは既知の不具合が修正されており、最新機能を高い安定性で提供します。
SQL デプロイメント
-
Realtime Compute for Apache Flink コンソール にログインします。ワークスペースを特定し、コンソール を 操作 列からクリックします。
-
現在の SQL ドラフトをバックアップします：
-
左側ナビゲーションウィンドウで、開発 > ETL を選択します。ドラフト タブで、ドラフト名をクリックします。
-
ドラフト画面の上部にある 名前を付けて保存 をクリックします。
-
ダイアログボックスで、名前 にファイル名を入力し、場所 を指定して、保存 をクリックします。
-
-
クローンしたドラフトに対象エンジンバージョンを設定します：
-
新しいドラフトの右側で、設定 タブをクリックします。エンジンバージョン のドロップダウンリストから対象バージョンを選択し、右上隅の デプロイ をクリックします。
-
エンジンバージョンの確認：左側ナビゲーションウィンドウで、O&M > デプロイメント を選択し、デプロイメント名をクリックします。設定 タブの 基本 セクションで、エンジンバージョンが変更されていることを確認します。
-
DataStream デプロイメント
-
Realtime Compute for Apache Flink コンソール にログインします。ワークスペースを特定し、コンソール を 操作 列からクリックします。
-
対象エンジンバージョンでデプロイメントをクローンします：
-
左側ナビゲーションウィンドウで、O&M > デプロイメント を選択し、デプロイメント名をクリックします。
-
右上隅の クローン をクリックします。
-
デプロイメント名 フィールドに新しい名前を入力し、エンジンバージョン のドロップダウンリストから対象バージョンを選択します。
-
-
デプロイ をクリックします。
ステップ 2：デプロイメントの状態のバックアップ
左側ナビゲーションウィンドウで、O&M > デプロイメント を選択し、デプロイメント名をクリックして、状態 タブで状態セットを確認します。詳細については、「状態セットの管理」の「状態生成の概要の表示」セクションをご参照ください。
-
状態保持型デプロイメント：アップグレード前に手動でセーブポイントを作成します。このセーブポイントは、アップグレード失敗時のロールバックポイントとして利用します。手順については、「状態セットの管理」の「手動によるセーブポイントの作成」セクションをご参照ください。
重要-
原則として、同一メジャーバージョン内のマイナーバージョン同士は互換がありますが、メジャーバージョン間の互換性は保証されません。互換がある場合、新しいエンジンは古いエンジンで生成されたセーブポイントを読み取れます。一方、古いエンジンは新しいエンジンで生成されたセーブポイントを読み取れない場合があります。
-
VVR 6.X 以降では、マイナーバージョンアップグレードにはネイティブフォーマット、メジャーバージョンアップグレードには標準フォーマットをご利用ください。
-
-
状態非保持型デプロイメント：次のステップに進んでください。
ステップ 3（任意）：元のデプロイメントのキャンセル
左側ナビゲーションウィンドウで、O&M > デプロイメント を選択し、元のデプロイメントを特定して、キャンセル を 操作 列からクリックします。詳細については、「デプロイメントのキャンセル」をご参照ください。
下流オペレーターが冪等な書き込みをサポートしている場合、または重複データがビジネス要件上許容される場合は、トランジション期間中に元のデプロイメントと新しいデプロイメントを同時に実行することも選択肢の一つです。
ステップ 4：新しいデプロイメントの開始
-
状態保持型デプロイメント：ジョブの開始 パネルで 再開モード を選択し、特定の状態 を指定して、ステップ 2 で作成したセーブポイントを選択します。
-
状態非保持型デプロイメント：ジョブの開始 パネルで 初期モード を選択します。
完全な手順については、「デプロイメントの開始」をご参照ください。
ステップ 5：アップグレードの検証とクリーンアップ
-
最初のチェックポイントの確認：新しいデプロイメントの開始後、最初のチェックポイントが完了するまで待ちます。最初のチェックポイントが正常に完了した場合、アップグレードは初期段階で成功しています。
-
ビジネスデータの監視：一定期間、ビジネスデータの正確性を観察し、アップグレードが完全に成功したことを確認します。
-
クリーンアップ：デプロイメントが正しく動作し、データが正確であることが確認できたら、元のデプロイメントおよびアップグレード前のセーブポイントを削除します。セーブポイントの削除手順については、「状態セットの管理」の「指定したセーブポイントの手動削除」セクションをご参照ください。
失敗したアップグレードのロールバック
新しいデプロイメントが起動に失敗した場合、またはアップグレード後に誤ったビジネスデータが出力された場合は、以下の手順を実行してください。
-
新しいデプロイメントをキャンセルします。
-
デプロイメントのエンジンバージョンを、アップグレード前のバージョンに戻します。
-
アップグレード前に保存したセーブポイントを使用してデプロイメントを起動し、業務継続性を回復します。
問題が継続する場合は、チケットを送信 してテクニカルサポートをご依頼ください。
アップグレード失敗を早期に検出するため、デプロイメント失敗アラートを設定することを推奨します。詳細については、「モニタリングおよびアラートの設定」をご参照ください。