更新时间:2022-12-07 GMT+08:00

查询作业执行进度信息

功能介绍

该API用于获取作业执行进度信息,如果作业正在执行,可以获取到子作业的信息,如果作业刚开始或者已经结束,则无法获取到子作业信息。

URI

  • URI格式:

    GET /v1/{project_id}/jobs/{job_id}/progress

  • 参数说明
    表1 URI 参数

    参数名称

    是否必选

    参数类型

    说明

    project_id

    String

    项目编号,用于资源隔离。获取方式请参考获取项目ID

    job_id

    String

    作业ID。

请求消息

无请求参数。

响应消息

表2 响应参数

参数名称

是否必选

参数类型

说明

is_success

Boolean

请求发送是否成功。“true”表示请求发送成功。

message

String

系统提示信息,执行成功时,信息可能为空。

job_id

String

提交请求成功时,生成并提交一个新的作业,返回作业ID。用户可以使用作业ID来查询作业状态和获取作业结果。

status

String

作业状态。状态可能为运行中(RUNNING)、规格变更中(SCALING)、提交中(LAUNCHING)、已完成(FINISHED)、已失败(FAILED)、已取消(CANCELLED)。

sub_job_id

Integer

正在运行的子作业ID,如果作业还没开始运行或者运行结束,则子作业ID可能为空。

progress

Double

正在运行的子作业的进度或者整个作业进度,该值只能粗略的估算子作业进度,不表示作业的详细进度。

  • 如果整个作业刚开始运行或者在提交中,则进度展示为0;如果作业运行结束,则进度展示为1。此时progress表示整个作业的运行进度,因为没有子作业在运行,sub_job_id不展示。
  • 如果有子作业在运行中,则展示该子作业的运行进度,progress的计算方法为:子作业已经完成的task数除以子作业总的task数。此时progress表示子作业的运行进度,sub_job_id展示。

sub_jobs

Array of Object

正在运行作业的子作业的详细信息,一个作业可能包含多个子作业。具体请参考表3

表3 sub_jobs参数说明

参数名称

是否必选

参数类型

说明

id

Integer

子作业ID,对应开源spark JobData的jobId。

name

String

子作业name,对应开源spark JobData的name。

description

String

子作业description,对应开源spark JobData的description。

submission_time

String

子作业submission_time,对应开源spark JobData的submissionTime。

completion_time

String

子作业completion_time,对应开源spark JobData的completionTime。

stage_ids

Array of Integer

子作业stage_ids,对应开源spark JobData的stageIds。

job_group

String

对应DLI的作业ID,对应开源spark JobData的jobGroup。

status

String

子作业状态,对应开源spark JobData的status。

num_tasks

Integer

子作业task的个数,对应开源spark JobData的numTasks。

num_active_tasks

Integer

子作业正在运行的task个数,对应开源spark JobData的numActiveTasks。

num_completed_tasks

Integer

子作业已经完成的task个数,对应开源spark JobData的numCompletedTasks。

num_skipped_tasks

Integer

子作业跳过的task个数,对应开源spark JobData的numSkippedTasks。

num_failed_tasks

Integer

子作业跳失败的task个数,对应开源spark JobData的numFailedTasks。

num_killed_tasks

Integer

子作业kill掉的task个数,对应开源spark JobData的numKilledTasks。

num_completed_indices

Integer

子作业完成指数,对应开源spark JobData的numCompletedIndices。

num_active_stages

Integer

子作业正在运行的stage个数,对应开源spark JobData的numActiveStages。

num_completed_stages

Integer

子作业已经完成的stage个数,对应开源spark JobData的numCompletedStages。

num_skipped_stages

Integer

子作业跳过的stage个数,对应开源spark JobData的numSkippedStages。

num_failed_stages

Integer

子作业失败的stage个数,对应开源spark JobData的numFailedStages。

killed_tasks_summary

Map<string,integer>

子作业killed_tasks_summary,对应开源spark JobData的killedTasksSummary。

请求示例

响应示例

{
    "is_success": true,
    "message": "",
    "job_id": "85798b38-ae44-48eb-bb90-7cf0dcdafe7b",
    "status": "RUNNING",
    "sub_job_id": 0,
    "progress": 0,
    "sub_jobs": [
        {
            "id": 0,
            "name": "runJob at FileFormatWriter.scala:266",
            "submission_time": "Mon Jul 27 17:24:03 CST 2020",
            "stage_ids": [
                0
            ],
            "job_group": "85798b38-ae44-48eb-bb90-7cf0dcdafe7b",
            "status": "RUNNING",
            "num_tasks": 1,
            "num_active_tasks": 1,
            "num_completed_tasks": 0,
            "num_skipped_tasks": 0,
            "num_failed_tasks": 0,
            "num_killed_tasks": 0,
            "num_completed_indices": 0,
            "num_active_stages": 1,
            "num_completed_stages": 0,
            "num_skipped_stages": 0,
            "num_failed_stages": 0
        }
    ]
}

状态码

状态码如表4所示。

表4 状态码

状态码

描述

200

查询成功。

400

请求错误。

错误码

调用接口出错后,将不会返回上述结果,而是返回错误码和错误信息,更多介绍请参见错误码

表5 错误码

错误码

错误信息

DLI.0999

The queue backend version is too old or the queue is busy.