Kinesis Data Analytics for Apache Flin - Amazon Kinesis Data Analytics
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

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

Kinesis Data Analytics for Apache Flin

本主题包含运行Amazon Kinesis Data Analytics for Apache Flink。

当你运行 Kinesis Data Analytics 应用程序时,Kinesis Data Analytics 服务会创建 Apache Flink 作业。Apache Flink 作业是 Kinesis Data Analytics 应用程序的执行生命周期。Job 的执行及其使用的资源由作业管理器管理。Job 管理器将应用程序的执行分成任务。每项任务都由任务管理器管理。监控应用程序的性能时,可以检查每个任务管理器的性能,也可以检查整个Job 管理器的性能。

有关 Apache Flink 任务的信息,请参阅 A pache Flink 文档中的任务和日程安排

申请和Job 状态

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

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

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

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

      • 正在运行:成功启动的应用程序处于 “正在运行” 状态。

    • 临时应用程序状态:处于这些状态的应用程序通常正在过渡到另一种状态。如果应用程序在一段时间内保持临时状态,则可以在Force参数设置为的情况下使用StopApplication操作来停止应用程序true。这些状态包括:

      • STARTING:StartApplication动作之后发生。应用程序正在从状态过渡READYRUNNING状态。

      • STOPPING:StopApplication动作之后发生。应用程序正在从状态过渡RUNNINGREADY状态。

      • DELETING:DeleteApplication动作之后发生。该应用程序正在删除 Application(删除)

      • UPDATING:UpdateApplication动作之后发生。应用程序正在更新,并将转换回RUNNINGREADY状态。

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

      • FORCE_STOPPING:Force参数设置为的情况下调用StopApplication操作后发生true。该应用程序正在强制停iew 应用程序从STARTINGUPDATINGSTOPPING、或AUTOSCALING状态过渡到READY状态。

      • ROLLING_BACK:在调用RollbackApplication操作后发生。该应用程序正在回滚到以前的版本。应用程序从UPDATINGAUTOSCALING状态过渡到RUNNING状态。

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

      • MAINTENANCE:在 Kinesis Data Analytics 向您的应用程序应用补丁时发生。有关更多信息,请参阅维护Kinesis Data Analytics 维护维护维护维护维护维护维护维护维护维护维护维护维护维护维护

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

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

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

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

    然后,应用程序会进入RESTARTINGFAILED状态,具体取决于是否可以重新启动作业。

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

批处理工作负载

Kinesis Data Analytics 支持运行 Apache Flink 批处理工作负载。在批处理作业中,当 Apache Flink 作业变为 “完成” 状态时,Kinesis Data Analytics 应用程序的状态设置为 “就”。有关 Flink 作业状态的更多信息,请参阅任务和调度