运行 Managed Service for Apache Flink 应用程序 - Managed Service for Apache Flink
识别应用程序和作业状态运行批处理工作负载

Amazon Managed Service for Apache Flink（Amazon MSF）之前称为 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有关自动扩展的信息，请参阅在 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 操作来检查应用程序的状态。

  • 任务状态：当您的应用程序处于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 任务状态的更多信息，请参阅任务和调度。