Managed Service for Apache Flink アプリケーションを実行する - Managed Service for Apache Flink
アプリケーションとジョブのステータスを特定するバッチワークロードを実行する

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

Managed Service for Apache Flink アプリケーションを実行する

このトピックには、Apache Flink 用 Managed Serviceの実行に関する情報が含まれています。

Apache Flink アプリケーション用 Managed Serviceを実行すると、サービスによって Apache Flink ジョブが作成されます。Apache Flink ジョブは、Apache Flink アプリケーション用 Managed Serviceの実行ライフサイクルです。Job の実行とそれが使用するリソースは、ジョブマネージャーによって管理されます。ジョブマネージャは、アプリケーションの実行をタスクに分割します。各タスクはタスクマネージャーによって管理されます。アプリケーションのパフォーマンスを監視する場合、各タスクマネージャーまたはジョブマネージャー全体のパフォーマンスを調べることができます。

Apache Flink ジョブの詳細については、Apache Flink ドキュメントの「Jobs and Scheduling」を参照してください。

アプリケーションとジョブのステータスを特定する

アプリケーションとアプリケーションのジョブの両方に現在の実行ステータスがあります。

  • 「アプリケーションステータス:」アプリケーションには、実行フェーズを説明する現在のステータスがあります。アプリケーション状態には以下のものがあります。

    • 「安定したアプリケーションステータス:」通常、ステータスを変更するまで、アプリケーションは次のステータスのままになります。

      • 「READY:」新規または停止中のアプリケーションは、実行するまで準備完了状態です。

      • 「RUNNING」正常に起動したアプリケーションは RUNNING ステータスになります。

    • 「一時的なアプリケーションステータス:」これらのステータスのアプリケーションは、通常、別のステータスへの移行中です。アプリケーションが一定時間一時的な状態のままである場合は、 Force パラメータを true に設定して 「StopApplication」 アクションを使用してアプリケーションを停止できます。これらのステータスには以下のものが含まれる：

      • STARTING: は「StartApplication」アクションの後に発生します。アプリケーションは READY から RUNNING ステータスに移行中です。

      • STOPPING: は 「StopApplication」 アクションの後に発生します。アプリケーションは RUNNING から READY ステータスに移行中です。

      • DELETING: は 「DeleteApplication」 アクションの後に発生します。アプリケーション は削除中です。

      • UPDATING: は 「UpdateApplication」 アクションの後に発生します。アプリケーションは更新中で、 RUNNING または READY ステータスに戻ります。

      • AUTOSCALING: アプリケーションでは 「ParallelismConfiguration 」 の AutoScalingEnabled プロパティが true に設定されており、サービスはアプリケーションの並列度を増やしています。「アプリケーション」 がこの状態の場合、使用できる有効な API アクションは、 Force パラメータを true に設定した StopApplication アクションだけです。自動スケーリングの詳細については、 「Managed Service for Apache Flink で自動スケーリングを使用する」 を参照してください。

      • FORCE_STOPPING: は Force パラメータを true に設定して「StopApplication」アクションが呼び出された後に発生します。アプリケーションは強制停止中です。アプリケーションはSTARTING 、UPDATING 、STOPPING または AUTOSCALING ステータスから READY ステータスに移行中です。

      • ROLLING_BACK: は 「rollbackApplication」 アクションが呼び出された後に発生します。アプリケーションを以前のバージョンにロールバックしています。アプリケーションは UPDATING または AUTOSCALING ステータスから RUNNING ステータスに移行します。

      • MAINTENANCE: は Managed Service for Apache Flinkがアプリケーションにパッチを適用しているときに発生します。詳細については、「Managed Service for Apache Flink のメンテナンスタスクを管理する」を参照してください。

    アプリケーションのステータスは、コンソールを使用するか、 「DescribeApplication」 アクションを使用して確認できます。

  • 「Job ステータス:」 アプリケーションが RUNNING ステータスになると、ジョブには現在の実行フェーズを説明するステータスが表示されます。ジョブは CREATED ステータスで開始し、開始後 RUNNING ステータスに進みます。エラー状態が発生すると、アプリケーションは次のステータスになります。

    • Apache Flink 1.11 以降を使用するアプリケーションでは、アプリケーションが RESTARTING ステータスになります。

    • Apache Flink 1.8 以前を使用するアプリケーションでは、アプリケーションが FAILING ステータスに入ります。

    その後、アプリケーションは、ジョブを再開できるかどうかに応じて、 RESTARTING または FAILED のステータスに進みます。

    ジョブのステータスは、アプリケーションの CloudWatch ログでステータスの変化を確認することで確認できます。

バッチワークロードを実行する

Apache Flink 用 Managed ServiceApache Flink 用 Managed Serviceは、バッチワークロードの実行をサポートしています。バッチジョブでは、Apache Flink ジョブが 「FINISHED」 ステータスになると、Apache Flink アプリケーションス用 Managed Service のテータスは 「READY」 に設定されます。Flink ジョブのステータスについて詳しくは、「ジョブとスケジューリング」 を参照してください。