查询作业执行进度信息
功能介绍
该API用于获取作业执行进度信息，如果作业正在执行，可以获取到子作业的信息，如果作业刚开始或者已经结束，则无法获取到子作业信息。
调试
您可以在API Explorer中调试该接口。
URI
- URI格式：
- 参数说明
表1 URI 参数 参数名称
是否必选
参数类型
说明
project_id
是
String
项目编号，用于资源隔离。获取方式请参考获取项目ID。
job_id
是
String
作业ID。
请求消息
无请求参数。
响应消息
|
参数名称 |
是否必选 |
参数类型 |
说明 |
|---|---|---|---|
|
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 |
正在运行的子作业的进度或者整个作业进度，该值只能粗略的估算子作业进度，不表示作业的详细进度。
|
|
sub_jobs |
否 |
Array of Object |
正在运行作业的子作业的详细信息，一个作业可能包含多个子作业。具体请参考表3。 |
|
参数名称 |
是否必选 |
参数类型 |
说明 |
|---|---|---|---|
|
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
}
]
}
错误码
调用接口出错后，将不会返回上述结果，而是返回错误码和错误信息，更多介绍请参见错误码。
|
错误码 |
错误信息 |
|---|---|
|
DLI.0999 |
The queue backend version is too old or the queue is busy. |
