

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

# 运行 Managed Service for Apache Flink 应用程序
<a name="how-running-apps"></a>

本主题包含如何创建 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 文档中的[任务和调度](https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/internals/job_scheduling/)。

## 识别应用程序和作业状态
<a name="how-running-job-status"></a>

您的应用程序和应用程序的作业都处于当前执行状态：
+ **应用程序状态：**您的应用程序的当前状态描述了其执行阶段。应用程序状态包括以下状态：
  + **稳定的应用程序状态：**在您更改状态之前，您的应用程序通常会保持以下状态：
    + **就绪：**在您运行之前，新的或已停止的应用程序将处于 “就绪” 状态。
    + **正在运行：**成功启动的应用程序处于 RUNNING 状态。
  + **临时应用程序状态：**处于这些状态的应用程序通常处于过渡到另一种状态的过程中。如果应用程序在一段时间内处于临时状态，则可以使用`Force`参数设置为的[StopApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_StopApplication.html)操作停止该应用程序`true`。这些状态包括以下内容：
    + `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:`应用程序的`AutoScalingEnabled`属性[ ParallelismConfiguration](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_ParallelismConfiguration.html)设置为`true`，并且该服务正在增加应用程序的并行度。当应用程序处于此状态时，您可以使用的唯一有效的 API [StopApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_StopApplication.html)操作是`Force`参数设置为的操作`true`。有关自动扩展的信息，请参阅[在 Managed Service for Apache Flink 中使用自动扩展](how-scaling-auto.md)。
    + `FORCE_STOPPING:`在`Force`参数设置为的情况下调用[StopApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_StopApplication.html)操作后发生`true`。应用程序正在被强制停止。应用程序从`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)操作来检查应用程序的状态。
+ **任务状态：**当您的应用程序处于`RUNNING`状态时，您的任务的状态描述了其当前执行阶段。任务以`CREATED`状态开始，然后在启动时进入`RUNNING`状态。如果出现错误情况，您的应用程序将进入以下状态：
  + 对于使用 Apache Flink 1.11 及更高版本的应用程序，您的应用程序将进入 `RESTARTING` 状态。
  + 对于使用 Apache Flink 1.8 及更早版本的应用程序，您的应用程序将进入该`FAILING`状态。

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

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

## 运行批处理工作负载
<a name="batch-workloads"></a>

Managed Service for Apache Flink 支持运行 Apache Flink 批处理工作负载。**在批处理任务中，当 Apache Flink 任务进入**已完成**状态时，Managed Service for Apache Flink 应用程序状态将设置为 “就绪”。**有关 Flink 任务状态的更多信息，请参阅[任务和](https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/internals/job_scheduling/)调度。