更新时间:2026-01-30 GMT+08:00
查询实时作业运行状态
功能介绍
查询指定实时作业的运行状态。
URI
- 参数说明
表1 URI参数说明 参数名
是否必选
参数类型
说明
project_id
是
String
项目编号,获取方法请参见项目ID和账号ID。
job_name
是
String
作业名称。
请求参数
| 参数名 | 是否必选 | 参数类型 | 说明 |
|---|---|---|---|
| workspace | 否 | String | 工作空间id。
|
响应参数
| 参数名 | 是否必选 | 参数类型 | 说明 |
|---|---|---|---|
| name | 是 | String | 解决方案名称。 |
| nodes | 否 | 列表数据结构 | 节点状态列表。 |
| status | 否 | String | 作业状态:
|
| startTime | 是 | Date | 启动时间。 |
| endTime | 否 | Date | 停止时间。 |
| lastUpdateTime | 否 | Date | 状态最后更新时间。 |
| 参数名 | 是否必选 | 参数类型 | 说明 |
|---|---|---|---|
| name | 是 | String | 节点名称。 |
| status | 否 | String | 节点状态:
|
| logPath | 否 | String | 节点运行日志路径 |
| type | 是 | String | 节点类型:
|
请求示例
查询实时作业job_sms作业运行状态以及各个节点运行状态。
GET /v1/b384b9e9ab9b4ee8994c8633aabc9505/jobs/job_sms/status 响应示例
- 成功响应
{ "name": "job_sms", "nodes": [ { "bufferRecords": 0, "jobInstanceId": 0, "LastInstanceStatus": "waiting", "name": "MRS_Flink_Job_8635", "speed": 0, "totalGetBytes": 0, "totalGetRecords": 0, "totalPutBytes": 0, "totalPutRecords": 0 } ], "status": "NORMAL" } - 失败响应
{ "error_code":"DLF.0100", "error_msg":"The job does not exists." }
父主题: 作业开发API