

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

# Managed Service for Apache Flink アプリケーションを実行する
<a name="how-running-apps"></a>

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

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

Apache Flink ジョブの詳細については、Apache Flink ドキュメントの「[Jobs and Scheduling](https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/internals/job_scheduling/)」を参照してください。

## アプリケーションとジョブのステータスを特定する
<a name="how-running-job-status"></a>

アプリケーションとアプリケーションのジョブの両方に現在の実行ステータスがあります。
+ 「**アプリケーションステータス:**」アプリケーションには、実行フェーズを説明する現在のステータスがあります。アプリケーション状態には以下のものがあります。
  + 「**安定したアプリケーションステータス:**」通常、ステータスを変更するまで、アプリケーションは次のステータスのままになります。
    + 「**READY:**」新規または停止中のアプリケーションは、実行するまで準備完了状態です。
    + 「**RUNNING**」正常に起動したアプリケーションは RUNNING ステータスになります。
  + 「**一時的なアプリケーションステータス:**」これらのステータスのアプリケーションは、通常、別のステータスへの移行中です。アプリケーションが一定時間一時的な状態のままである場合は、 `Force` パラメータを `true` に設定して 「[StopApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_StopApplication.html)」 アクションを使用してアプリケーションを停止できます。これらのステータスには以下のものが含まれる：
    + `STARTING:` は「[StartApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_StartApplication.html)」アクションの後に発生します。アプリケーションは `READY` から `RUNNING` ステータスに移行中です。
    + `STOPPING:` は 「[StopApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_StopApplication.html)」 アクションの後に発生します。アプリケーションは `RUNNING` から `READY` ステータスに移行中です。
    + `DELETING:` は 「[DeleteApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_DeleteApplication.html)」 アクションの後に発生します。アプリケーション は削除中です。
    + `UPDATING:` は 「[UpdateApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_UpdateApplication.html)」 アクションの後に発生します。アプリケーションは更新中で、 `RUNNING` または `READY` ステータスに戻ります。
    + `AUTOSCALING:` アプリケーションでは 「[ParallelismConfiguration ](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_ParallelismConfiguration.html)」 の `AutoScalingEnabled` プロパティが `true` に設定されており、サービスはアプリケーションの並列度を増やしています。「[アプリケーション](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_StopApplication.html)」 がこの状態の場合、使用できる有効な API アクションは、 `Force` パラメータを `true` に設定した StopApplication アクションだけです。自動スケーリングの詳細については、 「[Managed Service for Apache Flink で自動スケーリングを使用する](how-scaling-auto.md)」 を参照してください。
    + `FORCE_STOPPING:` は `Force` パラメータを `true` に設定して「[StopApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_StopApplication.html)」アクションが呼び出された後に発生します。アプリケーションは強制停止中です。アプリケーションは`STARTING` 、`UPDATING` 、`STOPPING` または `AUTOSCALING` ステータスから `READY` ステータスに移行中です。
    + `ROLLING_BACK:` は 「[rollbackApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_RollbackApplication.html)」 アクションが呼び出された後に発生します。アプリケーションを以前のバージョンにロールバックしています。アプリケーションは `UPDATING` または `AUTOSCALING` ステータスから `RUNNING` ステータスに移行します。
    + `MAINTENANCE:` は Managed Service for Apache Flinkがアプリケーションにパッチを適用しているときに発生します。詳細については、「[Managed Service for Apache Flink のメンテナンスタスクを管理する](maintenance.md)」を参照してください。

  アプリケーションのステータスは、コンソールを使用するか、 「[DescribeApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_DescribeApplication.html)」 アクションを使用して確認できます。
+ 「**Job ステータス:**」 アプリケーションが `RUNNING` ステータスになると、ジョブには現在の実行フェーズを説明するステータスが表示されます。ジョブは `CREATED` ステータスで開始し、開始後 `RUNNING` ステータスに進みます。エラー状態が発生すると、アプリケーションは次のステータスになります。
  + Apache Flink 1.11 以降を使用するアプリケーションでは、アプリケーションが `RESTARTING` ステータスになります。
  + Apache Flink 1.8 以前を使用するアプリケーションでは、アプリケーションが `FAILING` ステータスに入ります。

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

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

## バッチワークロードを実行する
<a name="batch-workloads"></a>

Apache Flink 用 Managed ServiceApache Flink 用 Managed Serviceは、バッチワークロードの実行をサポートしています。バッチジョブでは、Apache Flink ジョブが 「**FINISHED**」 ステータスになると、Apache Flink アプリケーションス用 Managed Service のテータスは 「**READY**」 に設定されます。Flink ジョブのステータスについて詳しくは、「[ジョブとスケジューリング](https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/internals/job_scheduling/)」 を参照してください。