运行适用于 Apache Flink 应用程序的托管服务 - Managed Service for Apache Flink
确定申请和工作状态运行批处理工作负载

Amazon Managed Service for Apache Flink 之前称为 Amazon Kinesis Data Analytics for Apache Flink。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

运行适用于 Apache Flink 应用程序的托管服务

本主题包含如何创建 Managed Service for Apache Flink 的相关信息。

当你运行 Managed Service for Apache Flink 应用程序时，该服务会创建一个 Apache Flink 任务。Apache Flink 任务是 Managed Service for Apache Flink 应用程序的执行生命周期。任务的执行及其使用的资源由 Job Manager 管理。Job Manager 将应用程序的执行分成多个任务。每项任务都由任务管理器管理。监控应用程序的性能时，可以检查每个任务管理器的性能，也可以检查整个 Job Manager 的性能。

有关 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。有关自动扩展的信息，请参阅在 Apache Flink 的托管服务中使用自动缩放。

      • FORCE_STOPPING:在Force参数设置为的情况下调用StopApplication操作后发生true。应用程序正在被强制停止。应用程序从STARTING、UPDATING、STOPPING或AUTOSCALING状态转换为 READY状态。

      • ROLLING_BACK:在调用RollbackApplication操作后发生。应用程序正在回滚到以前的版本。应用程序从 UPDATING或 AUTOSCALING状态转换到 RUNNING状态。

      • MAINTENANCE:在 Managed Service for Apache Flink 向您的应用程序应用补丁时发生。有关更多信息，请参阅 管理适用于 Apache Flink 的托管服务的维护任务。

    您可以使用控制台或使用DescribeApplication操作来检查应用程序的状态。

  • 任务状态：当您的应用程序处于RUNNING状态时，您的任务的状态描述了其当前执行阶段。任务以CREATED状态开始，然后在启动时进入RUNNING状态。如果出现错误情况，您的应用程序将进入以下状态：

    • 对于使用 Apache Flink 1.11 及更高版本的应用程序，您的应用程序将进入 RESTARTING 状态。

    • 对于使用 Apache Flink 1.8 及更早版本的应用程序，您的应用程序将进入该FAILING状态。

    然后，应用程序将进入RESTARTING或FAILED状态，具体取决于任务是否可以重新启动。

    您可以通过检查应用程序 CloudWatch 日志的状态更改来检查作业的状态。

运行批处理工作负载

Managed Service for Apache Flink 支持运行 Apache Flink 批处理工作负载。在批处理作业中，当 Apache Flink 作业进入FINISHED状态时，适用于 Apache Flink 的托管服务应用程序状态将设置为。READY有关 Flink 任务状态的更多信息，请参阅任务和调度。