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： 新しいアプリケーションまたは停止したアプリケーションは、実行するまで READYステータスになります。

      • RUNNING： 正常に開始されたアプリケーションは RUNNINGステータスです。

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

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

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

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

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

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

      • FORCE_STOPPING: Forceパラメータを に設定してStopApplicationアクションを呼び出した後に発生しますtrue。アプリケーションは強制停止中です。アプリケーションは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 ジョブのステータスについて詳しくは、「ジョブとスケジューリング」 を参照してください。