本文为您介绍如何查看作业的详情和状态,以及如何修改作业状态和配置信息。

查看作业详情

  1. 登录实时计算统一控制台
  2. Flink全托管页签,单击对应工作空间操作列下的开发控制台
  3. 在左侧导航栏上,单击Applications > Deployments
  4. 单击您创建的目标Deployment名称。
  5. 在目标Deployment详情页面,查看作业详情。
    • Overview:作业参数概览。概览
    • Job Graph:作业运行的Metric信息。 Job Graph
    • Events:作业运行中的事件。运行中的事件
      Events页面上默认展示作业的消息发生时间、消息简要描述和具体操作三部分信息。其中具体操作(Actions)包括以下操作:
      • Copy Message:复制错误信息。
      • Job Details:查看作业产生Event时的详细信息,包括配置、资源(CPU和内存)、作业运行参数、JAR包参数和Savepoint信息等。
        说明
        • 单击页面右上角Flink UI,可以跳转到运行作业的开源Flink UI界面。
        • 单击页面右上角Metric,可以跳转到运行作业的VVP(Ververica Platform)的Metric界面(Metric界面默认展示的是从Event发生时间起30分钟内的Metric信息)。
      • only show event for the job:展示当前Event对应的作业实例运行期间的事件。
    • Jobs:展示作业的历史信息,包括作业ID、启动时间、开始运行时间和状态等。Jobs

查看作业状态

  1. 登录实时计算统一控制台
  2. Flink全托管页签,单击对应工作空间操作列下的开发控制台
  3. 在左侧导航栏上,单击Applications > Deployments
  4. 单击您创建的目标Deployment名称。
  5. 在作业Overview页签,查看作业状态信息。
    页面右上角会显示两种作业状态:
    • Desired为期望状态,即操作后期望作业达到的最终状态,支持以下状态。
      Desired状态 说明
      RUNNING 按作业配置定义,启动作业。
      CANCELLED 停止任何正在运行的作业。
      SUSPENDED 先对当前运行的作业创建Savepoint,再停止作业。
    • Current为当前状态,支持以下状态。
      Current状态 说明
      RUNNING 按作业配置定义,启动作业。
      CANCELLED 停止任何正在运行的作业。
      SUSPENDED 先对当前运行的作业创建Savepoint,再停止作业。
      FINISHED 作业运行完成。
      TRANSITIONING 作业处于向期望状态的过度阶段。
      FAILED 作业向期望状态转换失败,需要手动处理。
    说明 单击Start启动作业后,作业的期望(Desired)状态会立刻变成RUNNING,当前(Current)状态会变成TRANSITIONING,并显示作业启动进度。前端开发平台VVP(Ververica Platform)会保证Flink作业最终达到期望状态。

    如果Flink作业状态正在从某个状态变成期望状态的过程中,而作业的最终期望状态发生了改变,作业会先到达最初的期望状态,再转换为最终的期望状态。

修改作业状态

  1. 登录实时计算统一控制台
  2. Flink全托管页签,单击对应工作空间操作列下的开发控制台
  3. 在左侧导航栏上,单击Applications > Deployments
  4. 单击您创建的目标Deployment名称。
  5. 单击Overview页签,进入作业详情页面。
  6. 根据需要单击以下按钮,修改作业状态。作业状态
    其中,每个按钮含义如下表所示。
    操作名称 说明
    Start 启动作业。
    Suspend 先对当前运行的作业创建Savepoint,再停止作业。
    说明 暂停作业需要具备以下两个条件:
    • Savepoint地址配置完成。如果Savepoint地址没有配置,Suspend操作将直接停止作业,导致作业状态的丢失。
    • Savepoint操作成功。
    Cancel 停止作业。
    Savepoint 创建一个当前时刻的Savepoint。
    说明 请先完成Savepoint地址配置,否则Savepoint会失败。
    Fork 复制一个作业。
    • 复制的作业处于CANCELLED状态。
    • 名称为原作业名称前增加前缀Fork of,例如Fork of test2
    Delete 删除作业。只能删除当前状态不为RUNNING的作业。

修改作业配置

作业配置包含作业上线阶段所有的配置内容。

  1. 登录实时计算统一控制台
  2. Flink全托管页签,单击对应工作空间操作列下的开发控制台
  3. 在左侧导航栏上,单击Applications > Deployments
  4. 单击您创建的目标Deployment名称。
  5. 修改作业配置。
    您可以通过两种方式修改作业配置:
    • 在图形化界面修改作业配置
      在页面左上角,单击Configure Deployment后,在Standard页签修改配置信息。配置信息
    • 在YAML文件中修改作业配置
      在页面左上角,单击Configure Deployment后,在YAML页签修改配置信息。YAML修改
  6. 修改后,单击Save Changes