Realtime Compute for Apache Flink:ジョブのクローンとエンジンバージョンのアップグレード

ステップ 1: ジョブのバックアップと新規ジョブのデプロイ

ジョブの安定性を確保するため、既存のジョブをクローンして同一の新規ジョブを作成し、その新規ジョブでエンジンバージョンをアップグレードします。

ステップ 2: ジョブステートのバックアップ

O&M > デプロイメント ページで、対象のジョブをクリックします。ジョブ詳細の ステート タブで、ジョブステートセットを表示します。詳細については、「ステート生成概要の表示」を参照してください。

• ジョブがステートフル計算を実行する場合、アップグレード中にステートを再利用できるかどうかを検討してください。

  アップグレード前に、ジョブのスナップショットを手動で作成しておくと、問題が発生した場合にすばやくロールバックできます。手順については、「ジョブスナップショットの手動作成」を参照してください。

  重要

  • 一般的に、同一メジャーバージョン内のマイナーバージョン間のアップグレードには互換性があります。メジャーバージョンをまたぐアップグレードについては、互換性は保証されません。互換性がある場合、新しいエンジンバージョンは古いバージョンで生成されたスナップショットを読み取ることができますが、その逆は必ずしも成り立ちません。

  • VVR 6.x 以降、システムはネイティブと標準の 2 つのスナップショット形式をサポートしています。ネイティブ形式は生成速度が速く、標準形式は互換性に優れています。同一メジャーバージョン内でより高いマイナーバージョンにアップグレードする場合は、ネイティブ形式を使用してください。より高いメジャーバージョンにアップグレードする場合は、標準形式を使用してください。

• ジョブがステートレスである場合は、次の手順に進んでください。

(オプション) 手順 3: 元のジョブを停止する

O&M > Deployments ページで、元のジョブの Actions 列にある Stop をクリックします。詳細については、「ジョブの停止」を参照してください。

ダウンストリームの書き込みが冪等であるか、またはビジネスが重複データを許容できる場合は、古いジョブと新しいジョブを同時に実行することを検討してください。

手順 4: 新しいジョブを開始する

• ジョブがステートフルである場合: Stateful Start で Specific State を選択し、元のジョブから作成されたスナップショットを選択します。

• ジョブがステートレスである場合は、Stateless を選択して新しいジョブを開始します。

起動手順の詳細については、「ジョブの開始」を参照してください。

手順 5: 本番環境の動作を監視し、元のジョブを削除する

通常、アップグレード後のジョブが正常に開始され、最初のシステムチェックポイントが完了すれば、アップグレードは暫定的に成功したとみなされます。ただし、アップグレードの完全性を確保するため、ビジネスデータの正確性を確認してください。

ジョブが正常に実行され、データが正しいことを確認したら、アップグレード前のジョブスナップショットおよびジョブを手動で削除します。スナップショットの削除手順については、「指定したジョブスナップショットの手動削除」を参照してください。