翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Flink 2.2 へのアップグレード: 完全なガイド

このガイドでは、Amazon Managed Service for Apache Flink アプリケーションを Flink 1.x から Flink 2.2 にアップグレードするstep-by-stepについて説明します。これは、慎重な計画とテストを必要とする重大な変更を伴うメジャーバージョンアップグレードです。

前提条件

アップグレードを開始する前に:

移行パスについて

アップグレードエクスペリエンスは、アプリケーションの Flink 2.2 との互換性によって異なります。これらのパスを理解することは、適切に準備し、現実的な期待を設定するのに役立ちます。

パス 1: 互換性のあるバイナリとアプリケーションの状態

予想されること:

最適: ステートレスアプリケーションまたは互換性のあるシリアル化を使用するアプリケーション (Avro、互換性のある Protobuf スキーマ、コレクションのない POJOs)

パス 2: バイナリ非互換性

予想されること:

最適: Flink ジョブの起動中に検出された削除APIs を使用するアプリケーション

パス 3: 互換性のないアプリケーションの状態

予想されること:

最適: 状態シリアル化の非互換性を持つアプリケーション (コレクションを持つ POJOs、特定の Kryo シリアル化状態)

フェーズ 1: 準備

アプリケーションコードを更新する

Flink 2.2 と互換性があるようにアプリケーションコードを更新します。

更新されたアプリケーションコードをアップロードする

フェーズ 2: 自動ロールバックを有効にする

自動ロールバックにより、Amazon Managed Service for Apache Flink は、アップグレードが失敗した場合に自動的に以前のバージョンに戻すことができます。

自動ロールバックステータスを確認する

AWS マネジメントコンソール:

AWS CLI:

aws kinesisanalyticsv2 describe-application \
    --application-name MyApplication \
    --query 'ApplicationDetail.ApplicationConfigurationDescription.ApplicationSystemRollbackConfigurationDescription.RollbackEnabled'

自動ロールバックを有効にする (有効になっていない場合)

aws kinesisanalyticsv2 update-application \
    --application-name MyApplication \
    --current-application-version-id <version-id> \
    --application-configuration-update '{
        "ApplicationSystemRollbackConfigurationUpdate": {
            "RollbackEnabledUpdate": true
        }
    }'

フェーズ 3: スナップショットを作成する (オプション)

アプリケーションで自動スナップショットが有効になっている場合は、このステップをスキップできます。それ以外の場合は、アップグレード前にアプリケーションのスナップショットを作成して、アプリケーションの状態を保存します。

実行中のアプリケーションからスナップショットを作成する

AWS マネジメントコンソール:

AWS CLI:

aws kinesisanalyticsv2 create-application-snapshot \
    --application-name MyApplication \
    --snapshot-name pre-flink-2.2-upgrade

スナップショットの作成を確認する

aws kinesisanalyticsv2 describe-application-snapshot \
    --application-name MyApplication \
    --snapshot-name pre-flink-2.2-upgrade

SnapshotStatus が になるまで待ってREADYから次に進みます。

フェーズ 4: アプリケーションをアップグレードする

UpdateApplication アクションを使用して Flink アプリケーションをアップグレードできます。

UpdateApplication API は複数の方法で呼び出すことができます。

アップグレードは、アプリケーションが RUNNING 状態のとき、またはアプリケーションが READY 状態で停止しているときに実行できます。Amazon Managed Service for Apache Flink は、元のランタイムバージョンとターゲットランタイムバージョンの互換性を検証します。この互換性チェックは、 RUNNING 状態UpdateApplication中に を実行したとき、または READY状態中にアップグレードStartApplicationしたときに実行されます。

RUNNING 状態からのアップグレード

aws kinesisanalyticsv2 update-application \
    --application-name MyApplication \
    --current-application-version-id <version-id> \
    --runtime-environment-update FLINK-2_2 \
    --application-configuration-update '{
        "ApplicationCodeConfigurationUpdate": {
            "CodeContentUpdate": {
                "S3ContentLocationUpdate": {
                    "FileKeyUpdate": "my-app-flink-2.2.jar"
                }
            }
        }
    }'

READY 状態からのアップグレード

aws kinesisanalyticsv2 update-application \
    --application-name MyApplication \
    --current-application-version-id <version-id> \
    --runtime-environment-update FLINK-2_2 \
    --application-configuration-update '{
        "ApplicationCodeConfigurationUpdate": {
            "CodeContentUpdate": {
                "S3ContentLocationUpdate": {
                    "FileKeyUpdate": "my-app-flink-2.2.jar"
                }
            }
        }
    }'

フェーズ 5: アップグレードをモニタリングする

互換性チェック

アプリケーションのヘルスをモニタリングする

アプリケーションの状態:

さらに、CloudWatch でこれらのメトリクスをモニタリングします。

再起動メトリクス:

チェックポイントメトリクス:

フェーズ 6: アプリケーションの動作を検証する

アプリケーションが Flink 2.2 で実行された後:

機能検証

パフォーマンス検証

24 時間以上実行

アプリケーションを本番環境で少なくとも 24 時間実行して、以下を確認します。

フェーズ 7: ロールバック手順

アップグレードが失敗するか、アプリケーションが実行されているが異常がある場合は、以前のバージョンにロールバックします。

自動ロールバック

自動ロールバックが有効で、起動中にアップグレードが失敗した場合、Amazon Managed Service for Apache Flink は自動的に以前のバージョンに戻ります。

手動ロールバック

アプリケーションが実行されているが異常がある場合は、 RollbackApplication API を使用します。

AWS マネジメントコンソール:

AWS CLI:

aws kinesisanalyticsv2 rollback-application \
    --application-name MyApplication \
    --current-application-version-id <version-id>

ロールバック中に何が起こるか:

次の手順

アップグレード中の質問や問題については、「」を参照Managed Service for Apache Flink をトラブルシューティングするするか、 AWS サポートにお問い合わせください。