完成作业提交后,您可以作业详情页面对作业进行操作并查看作业信息。

登录作业详情页面

  1. 登录实时计算云原生开发控制台。登录步骤请参见开通实时计算云原生模式
  2. 在作业总览页面,单击目标作业,进入作业详情页面。

作业详情展示

  • 作业状态
    分为期望(Desired)状态和当前(Current)状态。Desired是您操作后期望作业达到的最终状态;Current则标记了作业目前的阶段。
    • 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作业状态正在从某个状态变成期望状态的过程中,而作业的最终期望状态发生了改变,作业会先到达最初的期望状态,再转换为最终的期望状态。
  • 作业操作
    • 作业配置Configure Deployment
      作业配置包含作业上线阶段所有的配置内容。您可以通过Configure Deployment选择使用图形化界面或者YAML文件的方式进行修改。
      • 图形化界面进行修改。
        单击Configure Deployment,在图形化界面进行配置信息修改。
      • 编辑YAML文件进行修改。
        1. 单击Configure Deployment右侧的更多图标
        2. 单击Edit as YAML
        3. Deployment as YAML页面修改配置信息。
    • 作业状态
      操作名称 说明
      Start 启动作业。
      Suspend 先对当前运行的作业创建Savepoint,再停止作业。
      说明 暂停作业需要具备以下两个条件:
      • Savepoint地址配置完成。若Savepoint地址没有配置,Suspend操作将直接停止作业,导致作业状态的丢失。
      • Savepoint操作成功。
      Cancel 停止作业。
      Savepoint 创建一个当前时刻的Savepoint。
      说明 请先完成Savepoint地址配置,否则Savepoint会失败。
      Fork 复制一个作业。
      • 复制的作业处于CANCELLED状态。
      • 名称为原作业名称前增加前缀Fork of,例如Fork of test2
      Flink UI 跳转到该作业的开源FLINK UI界面。
      Delete 删除作业。只能删除当前状态不为RUNNING的作业。
    • 作业信息
      • Overview:作业参数概览。
      • Job Graph:作业运行的DAG图。
        DAG图中展示了DAGnumRecordsInPerSecondlastCheckpointSize的Metric信息。
      • Events:作业运行中的事件。
        Events页面上默认展示作业的消息发生时间(Time)、消息简要描述(Message)和具体操作(Actions)等三部分信息。其中具体操作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:展示作业的历史信息,包含Job ID、启动时间、开始运行时间和状态等。从状态中可以查看正在运行作业的Flink UI、历史和现在作业的Metric信息。
      • Savepoints:展示作业Savepoint相关信息。
        包括Savepoint历史信息和下次作业恢复会使用的Savepoint。其中Action包含以下操作:
        • Copy URL:复制当前Savepoint的URL路径。
        • Reset to Savepoint:将某个Savepoint设置为下次作业恢复时使用的Savepoint。
        • Fork Deployment from Savepoint:复制某个Savepoint时刻的作业,该作业会携带该Savepoint形成一个新的作业,名称是Fork of <jobName>,例如Fork of test2
      • Metric:作业运行的Metric信息。
        您也可以在该页面编辑信息自主查看作业信息,相关Metric以及含义参见社区文档