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 アプリケーションを実行する

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

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

Apache Flink ジョブの詳細については、「Apache Flink ドキュメント」の「ジョブとスケジューリング」を参照してください。

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

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

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

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

      • 「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 ジョブのステータスについて詳しくは、「ジョブとスケジューリング」 を参照してください。