Managed Service for Apache Flink アプリケーションのシステムロールバックを有効にする - Managed Service for Apache Flink

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

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

Managed Service for Apache Flink アプリケーションのシステムロールバックを有効にする

システムロールバック機能を使用すると、Amazon Managed Service for Apache Flink で実行中の Apache Flink アプリケーションの可用性を高めることができます。この設定をオプトインすると、 UpdateApplicationや などのアクションがコードや設定のバグに陥ったときに、サービスがアプリケーションを自動的に以前のautoscaling実行バージョンに戻すことができます。

注記

システムロールバック機能を使用するには、アプリケーションを更新してオプトインする必要があります。既存のアプリケーションは、デフォルトではシステムロールバックを自動的に使用しません。

仕組み

更新アクションやスケーリングアクションなどのアプリケーションオペレーションを開始すると、Amazon Managed Service for Apache Flink はそのオペレーションの実行を最初に試みます。コードのバグやアクセス許可の不足など、オペレーションが成功しない問題が検出されると、サービスは自動的にRollbackApplicationオペレーションを開始します。

ロールバックは、関連付けられたアプリケーションの状態とともに、正常に実行された以前のバージョンにアプリケーションを復元しようとします。ロールバックが成功すると、アプリケーションは以前のバージョンを使用して最小限のダウンタイムでデータの処理を続行します。自動ロールバックも失敗した場合、Amazon Managed Service for Apache Flink はアプリケーションを READYステータスに移行し、エラーの修正やオペレーションの再試行など、さらにアクションを実行できるようにします。

自動システムロールバックを使用するにはオプトインする必要があります。コンソールを使用するか、この時点からアプリケーションのAPIすべてのオペレーションで有効にできます。

次の UpdateApplicationアクションのリクエスト例では、アプリケーションのシステムロールバックを有効にします。

{ "ApplicationName": "MyApplication", "CurrentApplicationVersionId": 1, "ApplicationConfigurationUpdate": { "ApplicationSystemRollbackConfigurationUpdate": { "RollbackEnabledUpdate": "true" } } }

自動システムロールバックの一般的なシナリオを確認する

次のシナリオは、自動システムロールバックが有益な場所を示しています。

  • アプリケーションの更新: メインメソッドを使用して Flink ジョブを初期化するときにバグがある新しいコードでアプリケーションを更新すると、自動ロールバックによって以前の動作バージョンを復元できます。システムロールバックが役立つその他の更新シナリオは次のとおりです。

    • アプリケーションが更新され、 よりも高い並列処理で実行される場合maxParallelism

    • アプリケーションが更新され、Flink ジョブの起動中に障害が発生するVPCアプリケーションのサブネットが間違って実行された場合。

  • Flink バージョンのアップグレード: 新しい Apache Flink バージョンにアップグレードし、アップグレードされたアプリケーションにスナップショットの互換性の問題が発生すると、システムロールバックにより、以前の Flink バージョンに自動的に戻ることができます。

  • AutoScaling: スナップショットと Flink ジョブグラフのオペレータが一致しないため、アプリケーションがスケールアップしてもセーブポイントからの復元に問題が発生する場合。

システムロールバックAPIsに オペレーションを使用する

可視性を高めるために、Amazon Managed Service for Apache Flink には、障害や関連するシステムロールバックの追跡に役立つアプリケーションオペレーションAPIsに関連する 2 つの があります。

ListApplicationOperations

これによりUpdateApplication、、、 など、アプリケーションで実行されたすべてのオペレーションが時系列の逆順MaintenanceRollbackApplicationでAPI一覧表示されます。次の ListApplicationOperationsアクションのリクエスト例では、アプリケーションの最初の 10 個のアプリケーションオペレーションを一覧表示します。

{ "ApplicationName": "MyApplication", "Limit": 10 }

次の のリクエスト例は、リストをアプリケーションの以前の更新にフィルタリングするListApplicationOperationsのに役立ちます。

{ "ApplicationName": "MyApplication", "operation": "UpdateApplication" }

DescribeApplicationOperation

これによりAPI、該当する場合、障害の理由などListApplicationOperations、 にリストされている特定のオペレーションに関する詳細情報が提供されます。次の DescribeApplicationOperationアクションのリクエスト例では、特定のアプリケーションオペレーションの詳細を一覧表示します。

{ "ApplicationName": "MyApplication", "OperationId": "xyzoperation" }

トラブルシューティング情報については、システムロールバックのベストプラクティスを参照してください。