アプリケーションのアップグレードに関する一般的なベストプラクティスと推奨事項 - Managed Service for Apache Flink

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

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

アプリケーションのアップグレードに関する一般的なベストプラクティスと推奨事項

  • 本番稼働用アップグレードを試みる前に、非本番稼働環境で状態なしで新しいジョブ/ランタイムをテストします。

  • まず、非本番稼働用アプリケーションでステートフルアップグレードをテストすることを検討してください。

  • 新しいジョブグラフに、アップグレードされたアプリケーションの起動に使用するスナップショットと互換性がある状態になっていることを確認します。

    • 演算子の状態に保存されている型が同じままであることを確認してください。タイプが変更された場合、Apache Flink はオペレータの状態を復元できません。

    • uid メソッドを使用して設定したオペレーター IDs が同じままであることを確認してください。Apache Flink には、演算子に一意の IDsための強力な推奨事項があります。詳細については、Apache Flink ドキュメントの「オペレータ IDs」を参照してください。

      演算子に IDs を割り当てない場合、Flink は自動的に ID を生成します。その場合、プログラム構造に依存し、変更すると互換性の問題が発生する可能性があります。Flink は、オペレータ IDs を使用してスナップショットの状態をオペレータに一致させます。オペレータ IDs を変更すると、アプリケーションが起動しないか、スナップショットに保存されている状態がドロップされ、新しいオペレータが状態なしで開始されます。

    • キー付き状態の保存に使用されるキーを変更しないでください。

    • ウィンドウや結合などのステートフル演算子の入力タイプを変更しないでください。これにより、オペレーターの内部状態のタイプが暗黙的に変更され、状態が非互換性になります。