运行 Managed Service for Apache Flink 应用程序 - Managed Service for Apache Flink
应用程序和任务状态批处理工作负载
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

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

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

运行 Managed Service for 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 文档中的任务和调度。

应用程序和任务状态

您的应用程序和应用程序的任务都处于当前执行状态：

  • 应用程序状态：您的应用程序的当前状态描述了其执行阶段。应用程序状态包括以下状态：

    • 稳定的应用程序状态：在您更改状态之前，您的应用程序通常会保持以下状态：

      • 就绪：在您运行之前，新的或已停止的应用程序将处于 “就绪” 状态。

      • 正在运行：成功启动的应用程序处于 RUNNING 状态。

    • 临时应用程序状态：处于这些状态的应用程序通常处于过渡到另一种状态的过程中。如果应用程序在一段时间内处于临时状态，则可以使用 停止应用程序 操作停止该应用程序，Force参数设置为true。这些状态包括以下内容：

      • STARTING:在 “启动应用程序” 操作之后发生。应用程序正在从状态过渡READY到RUNNING状态。

      • STOPPING:在 “停止应用程序” 操作之后发生。应用程序正在从状态过渡RUNNING到READY状态。

      • DELETING:在 “删除应用程序” 操作之后发生。应用程序正在删除中。

      • UPDATING:在 “更新应用程序” 操作之后发生。应用程序正在更新，并将转换回RUNNING或READY状态。

      • AUTOSCALING:应用程序的 ParallelismConfigurationAutoScalingEnabled 属性设置为true，并且该服务正在增加应用程序的并行度。当应用程序处于此状态时，您可以使用的唯一有效的 API 操作是Force参数设置为 停止应用程序 操作。true有关自动扩展的信息，请参阅自动扩展。

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

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

      • ROLLED_BACK:成功回滚应用程序后，这将成为您从中回滚的版本的状态。有关回滚应用程序的信息，请参阅 RollbackApplication。

      • MAINTENANCE:在 Managed Service for Apache Flink 向您的应用程序应用补丁时发生。有关更多信息，请参阅Managed Service for 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 任务进入已完成状态时，Managed Service for Apache Flink 应用程序状态将设置为 “就绪”。有关 Flink 任务状态的更多信息，请参阅任务和调度。