运行 Apache Flink 应用程序的 Kinesis Data Analytics - Amazon Kinesis Data Analytics
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

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

运行 Apache Flink 应用程序的 Kinesis Data Analytics

本主题包含有关运行 Apache Flink 应用程序的 Kinesis Data Analytics 应用程序的信息。

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

有关 Apache Flink 作业的信息,请参阅作业和计划中的Apache Flink 文档.

任务申请和 Job 状态

你的申请和应用程序的作业都有当前的执行状态:

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

    • 稳定的应用程序状态:在进行状态更改之前,您的应用程序通常会保持这些状态:

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

      • 运行:成功启动的应用程序处于 RUNING 状态。

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

      • STARTING:发生在StartApplicationaction. 应用程序正在从READYRUNNING状态。

      • 停止:发生在StopApplicationaction. 应用程序正在从RUNNINGREADY状态。

      • DELETING:发生在DeleteApplicationaction. 该应用程序正在删除中。

      • UPDATING:发生在UpdateApplicationaction. 应用程序正在更新,并将过渡回RUNNING要么READY状态。

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

      • FORCE_STOPPING:发生在StopApplication动作是用Force设置参数为true. 该应用程序正在强制停止中。应用程序从STARTINGUPDATINGSTOPPING,或者AUTOSCALING状态为READY状态。

      • ROLLING_BACK:发生在RollbackApplication行动被称为。该应用程序正在回滚到以前的版本。应用程序从UPDATING要么AUTOSCALING状态为RUNNING状态。

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

      • MAINTENANCE:当 Kinesis Data Analytics 将修补程序应用于应用程序时发生。有关更多信息,请参阅 针对 Apache Flink 维护的 Kinesis Data Analytics

    您可以使用控制台或使用DescribeApplicationaction.

  • Job 状态:当你的应用程序在RUNNING状态,您的作业的状态描述了其当前执行阶段。一份工作从CREATED状态,然后继续转到RUNNING启动时的状态。如果出现错误情况,您的应用程序将进入以下状态:

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

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

    然后,应用程序将进入RESTARTING要么FAILED状态,取决于是否可以重新启动作业。

    你可以通过检查你的申请来查看工作的状态CloudWatch状态变化记录。

批处理工作负载

Kinesis Data Analytics 支持运行 Apache Flink 批处理工作负载。在批处理作业中,当 Apache Flink 作业到达完成状态,Kinesis Data Analytics 应用程序状态设置为准备好了. 有关 Flink 作业状态的更多信息,请参阅作业和计划.