Apache Flink のインプレースバージョンアップグレードを使用してアプリケーションをアップグレードする - Managed Service for Apache Flink
アップグレード前: Apache Flink アプリケーションを更新する

Amazon Managed Service for Apache Flink は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。

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

Apache Flink のインプレースバージョンアップグレードを使用してアプリケーションをアップグレードする

開始する前に、このビデオを視聴することをお勧めします: インプレースバージョンアップグレード 。

Apache Flink のインプレースバージョンアップグレードを実行するには、 AWS CLI、 AWS CloudFormation AWS SDK、または を使用できます AWS Management Console。この機能は、 READYまたは RUNNING状態の Managed Service for Apache Flink で使用する既存のアプリケーションで使用できます。を使用して UpdateApplication API、Flink ランタイムを変更する機能を追加します。

アップグレード前: Apache Flink アプリケーションを更新する

Flink アプリケーションを記述するときは、それらの依存関係をアプリケーションにバンドルJARし、Amazon S3 バケットJARに をアップロードします。そこから、Amazon Managed Service for Apache Flink は、選択した新しい Flink ランタイムでジョブを実行します。アップグレード先の Flink ランタイムとの互換性を実現するために、アプリケーションを更新する必要がある場合があります。バージョンのアップグレードが失敗する原因となる Flink バージョン間に矛盾がある可能性があります。最も一般的なのは、ソース (進入) または送信先 (シンク、進出) と Scala の依存関係のコネクタです。Managed Service for Apache Flink の Flink 1.15 以降のバージョンは Scala に依存しないため、 には使用する Scala のバージョンが含まれているJAR必要があります。

アプリケーションを更新するには

  1. 状態のアプリケーションのアップグレードに関する Flink コミュニティからのアドバイスをお読みください。「アプリケーションと Flink バージョンのアップグレード」を参照してください。

  2. 既知の問題と制限のリストをお読みください。「アプリケーションのアップグレードに関する注意事項と既知の問題」を参照してください。

  3. 依存関係を更新し、アプリケーションをローカルでテストします。これらの依存関係は通常、次のとおりです。

    1. Flink ランタイムと API。

    2. 新しい Flink ランタイムに推奨されるコネクタ。更新先の特定のランタイムのリリースバージョンで、これらを確認できます。

    3. Scala – Apache Flink は、Flink 1.15 以降は Scala に依存しません。アプリケーション で使用する Scala 依存関係を含める必要がありますJAR。

  4. zipfile JAR に新しいアプリケーションを構築し、Amazon S3 にアップロードします。前の JAR/zipfile とは異なる名前を使用することをお勧めします。ロールバックする必要がある場合は、この情報を使用します。

  5. ステートフルアプリケーションを実行している場合は、現在のアプリケーションのスナップショットを作成することを強くお勧めします。これにより、アップグレード中またはアップグレード後に問題が発生した場合に、ステートリーにロールバックできます。