查询作业列表
功能介绍
查询当前用户的作业列表,可以根据作业ID作为ID,查询大于ID或小于ID的限定条数的作业,默认查询全部状态的作业,也可以设定运行中或其他状态条件。
URI
- URI格式
- 参数说明
表1 URI参数说明 参数名称
是否必选
参数类型
说明
project_id
是
String
参数解释:
项目编号,用于资源隔离。获取方式请参考获取项目ID。
示例: 48cc2c48765f481480c7db940d6409d1
约束限制:
无
取值范围:
只能由英文字母和数字组成,且长度为[1-64]个字符。
默认取值:
无
表2 query参数说明 参数名称
是否必选
参数类型
说明
job_type
否
String
参数解释:
作业类型。
约束限制:
无
取值范围:
- flink_sql_job:flink sql作业
- flink_opensource_sql_job:flink opensource sql作业
- flink_jar_job:flink自定义作业
默认取值:
无
status
否
String
参数解释:
作业状态码。
约束限制:
无
取值范围:
- job_init:草稿
- job_submitting:提交中
- job_submit_fail:提交失败
- job_running:运行中(开始计费,提交作业后,返回正常结果)
- job_running_exception:运行异常(停止计费。作业发生运行时异常,停止运行作业)
- job_downloading:下载中
- job_idle:空闲
- job_canceling:停止中
- job_cancel_success:已停止
- job_cancel_fail:停止失败
- job_savepointing:保存点创建中
- job_arrearage_stopped:因欠费被停止(结束计费。用户账户欠费,作业停止)
- job_arrearage_recovering:欠费作业恢复中(用户账户欠费,账户充值,作业恢复中)
- job_finish:已完成
默认取值:
无
queue_name
否
String
参数解释:
队列名称。
约束限制:
无
取值范围:
无
默认取值:
无
order
否
String
参数解释:
查询结果排序。
约束限制:
无
取值范围:
- asc:按照时间顺序升序排列
- desc:按照时间顺序降序排列
默认取值:
默认为“desc”。
limit
否
Integer
参数解释:
返回的数据条数。
约束限制:
最大值为“100”
取值范围:
0-100
默认取值:
默认为“10”。
name
否
String
参数解释:
作业名称。
约束限制:
长度限制:0-57个字符。
取值范围:
无
默认取值:
无
offset
否
Integer
参数解释:
作业偏移量。
约束限制:
无
取值范围:
无
默认取值:
无
show_detail
否
Boolean
参数解释:
是否返回作业详情信息。默认为“false”。为“true”时,返回作业详情。具体可见查询作业详情。
约束限制:
无
取值范围:
无
默认取值:
false
user_name
否
String
参数解释:
用户名,可作为筛选条件。
约束限制:
无
取值范围:
无
默认取值:
无
tags
否
String
参数解释:
指定标签过滤。
约束限制:
无
取值范围:
无
默认取值:
无
请求消息
无请求参数。
响应消息
参数名称 |
是否必选 |
参数类型 |
说明 |
---|---|---|---|
is_success |
否 |
String |
参数解释: 执行请求是否成功。 取值范围: “true”:表示请求执行成功。 “false”:表示请求执行失败。 |
message |
否 |
String |
参数解释: 系统提示信息,执行成功时,该值为空。 取值范围: 无 |
job_list |
否 |
Object |
参数解释: 作业列表信息。请参见表4。 取值范围: 无 |
参数名称 |
是否必选 |
参数类型 |
说明 |
---|---|---|---|
total_count |
否 |
Integer |
参数解释: 作业查询结果条数。 取值范围: 无 |
jobs |
否 |
Array of Objects |
参数解释: 作业信息。请参见表5。 取值范围: 无 |
参数名称 |
是否必选 |
参数类型 |
说明 |
---|---|---|---|
job_id |
否 |
Long |
参数解释: 作业ID。 取值范围: 无 |
name |
否 |
String |
参数解释: 作业名称。 取值范围: 长度限制:0-57个字符。 |
desc |
否 |
String |
参数解释: 作业描述。 取值范围: 长度限制:0-512个字符。 |
user_name |
否 |
String |
参数解释: 用户名,当“show_detail”为“false”时独有。 取值范围: 长度在[1,128]范围内的字符串 |
job_type |
否 |
String |
参数解释: 作业类型。 取值范围:
|
status |
否 |
String |
参数解释: 作业状态。 取值范围:
|
status_desc |
否 |
String |
参数解释: 作业状态描述。 取值范围: 无 |
create_time |
否 |
Long |
参数解释: 作业创建时间。示例: 1516952770835 取值范围: 大于等于0的整数。 |
start_time |
否 |
Long |
参数解释: 作业启动时间。“0”表示尚未启动。 示例: 1516952710740 取值范围: 大于等于0的整数。 |
duration |
否 |
Long |
参数解释: 作业运行时长。 单位ms,“show_detail”为“false”时独有。 取值范围: 大于等于0的整数。 |
root_id |
否 |
Long |
参数解释: 父作业ID。“show_detail”为“false”时独有。 取值范围: 无 |
graph_editor_enabled |
否 |
Boolean |
参数解释: 作业的流图是否可编辑。“true”表示作业的流图可以编辑,“false”表示作业的流图不可以编辑。 取值范围: 无 |
has_savepoint |
否 |
Boolean |
参数解释: 作业是否有保存点。“true”表示作业有保存点,“false”表示作业没有保存点。 取值范围: 无 |
user_id |
否 |
String |
参数解释: 作业所属用户标识。 “show_detail”为“true”时独有。 取值范围: 无 |
project_id |
否 |
String |
参数解释: 作业所属项目标识。 “show_detail”为“true”时独有。 取值范围: 无 |
sql_body |
否 |
String |
参数解释: Stream SQL语句。 “show_detail”为“true”时独有。 取值范围: 无 |
run_mode |
否 |
String |
参数解释: 作业运行模式。包括共享、独享模式和边缘节点。“show_detail”为“true”时独有。 取值范围:
|
job_config |
否 |
Object |
参数解释: 作业配置。 “show_detail”为“true”时独有。具体参数说明请参见表6。 取值范围: 无 |
main_class |
否 |
String |
参数解释: jar包主类。“show_detail”为“true”时独有。 取值范围: 无 |
entrypoint_args |
否 |
String |
参数解释: jar包作业运行参数。多个参数之间用空格分隔。“show_detail”为“true”时独有。 取值范围: 无 |
execution_graph |
否 |
String |
参数解释: 作业执行计划。“show_detail”为“true”时独有。 取值范围: 无 |
update_time |
否 |
Long |
参数解释: 作业更新时间。“show_detail”为“true”时独有。 取值范围: 无 |
queue_name |
否 |
String |
参数解释: 队列名称。 取值范围: 无 |
edge_group_ids |
否 |
Array of Strings |
参数解释: 边缘计算组ID列表。多个ID以逗号分隔。 取值范围: 无 |
restart_times |
否 |
Integer |
参数解释: 重启次数。 取值范围: 无 |
savepoint_path |
否 |
String |
参数解释: 手动产生的Checkpoint的保存路径。 取值范围: 无 |
参数名称 |
是否必选 |
参数类型 |
说明 |
---|---|---|---|
checkpoint_enabled |
否 |
Boolean |
参数解释: 是否开启作业自动快照功能。 取值范围:
默认为“false”。 |
checkpoint_mode |
否 |
String |
参数解释: 快照模式,。 取值范围: 两种可选:
默认值为“exactly_once”。 |
checkpoint_interval |
否 |
Integer |
参数解释: 快照时间间隔。 单位为秒,默认值为“10”。 取值范围: 无 |
log_enabled |
否 |
Boolean |
参数解释: 是否启用日志存储。默认为“false”。 取值范围: true:启用日志存储。 false:不启用日志存储。 |
obs_bucket |
否 |
String |
参数解释: OBS桶名。 取值范围: 无 |
smn_topic |
否 |
String |
参数解释: SMN主题名。当作业异常时,向该SMN主题推送告警信息。 取值范围: 无 |
root_id |
否 |
Integer |
参数解释: 父作业ID。 取值范围: 无 |
edge_group_ids |
否 |
Array of Strings |
参数解释: 边缘计算组ID列表。多个ID以逗号分隔。 取值范围: 无 |
manager_cu_number |
否 |
Integer |
参数解释: 管理单元CU数。默认为“1”。 取值范围: 无 |
cu_number |
否 |
Integer |
参数解释: 用户为作业选择的CU数量。 “show_detail”为“true”时独有。
默认为“2”。 取值范围: 无 |
parallel_number |
否 |
Integer |
参数解释: 用户设置的作业并行数。 “show_detail”为“true”时独有。
默认为“1”。 取值范围: 无 |
restart_when_exception |
否 |
Boolean |
参数解释: 是否开启异常重启功能。 取值范围: 无 |
idle_state_retention |
否 |
Integer |
参数解释: 空闲状态过期周期。 取值范围: 无 |
udf_jar_url |
否 |
String |
参数解释: 用户已上传到DLI资源管理系统的程序包名,用户sql作业的udf jar通过该参数传入。 取值范围: 无 |
dirty_data_strategy |
否 |
String |
参数解释: 作业脏数据策略。 取值范围:
|
entrypoint |
否 |
String |
参数解释: 用户已上传到DLI资源管理系统的程序包名,用户自定义作业主类所在的jar包。 取值范围: 无 |
dependency_jars |
否 |
Array of Strings |
参数解释: 用户已上传到DLI资源管理系统的程序包名,用户自定义作业的其他依赖包。 取值范围: 无 |
dependency_files |
否 |
Array of Strings |
参数解释: 用户已上传到DLI资源管理系统的资源包名,用户自定义作业的依赖文件。 取值范围: 无 |
executor_number |
否 |
Integer |
参数解释: 作业使用计算节点个数。 取值范围: 无 |
executor_cu_number |
否 |
Integer |
参数解释: 计算节点CU数。 取值范围: 无 |
execution_agency_urn |
否 |
String |
参数解释: 参授权给DLI的委托名。 Flink1.15版本时支持配置该参数。 取值范围: 无 |
resume_checkpoint |
否 |
Boolean |
参数解释: 异常自动重启时,是否从最新checkpoint恢复。默认值为“false”。 取值范围: 无 |
runtime_config |
否 |
String |
参数解释: Flink作业运行时自定义优化参数。 取值范围: 无 |
graph_editor_enabled |
否 |
Boolean |
参数解释: 流图编辑开关。默认为“false”。 取值范围: 无 |
graph_editor_data |
否 |
String |
参数解释: 流图编辑数据。默认为null。 取值范围: 无 |
resume_max_num |
否 |
Integer |
参数解释: 异常重试最大次数。-1代表无限。 取值范围: 无 |
checkpoint_path |
否 |
String |
参数解释: 检查点保存路径。 取值范围: 无 |
config_url |
否 |
String |
参数解释: 用户上传的config包OBS路径。 取值范围: 无 |
tm_cus |
否 |
int |
参数解释: 单TM所占CU数。 取值范围: 无 |
tm_slot_num |
否 |
int |
参数解释: 单TM Slot数。 取值范围: 无 |
image |
否 |
String |
参数解释: 自定义镜像。格式为:组织名/镜像名:镜像版本。 当用户设置“feature”为“custom”时,该参数生效。用户可通过与“feature”参数配合使用,指定作业运行使用自定义的Flink镜像。关于如何使用自定义镜像,请参考《数据湖探索用户指南》。 取值范围: 无 |
feature |
否 |
String |
参数解释: 自定义作业特性。表示用户作业使用的Flink镜像类型。 取值范围:
|
flink_version |
否 |
String |
参数解释: Flink版本。当用户设置“feature”为“basic”时,该参数生效。用户可通过与“feature”参数配合使用,指定作业运行使用的DLI基础Flink镜像的版本。 取值范围: 无 |
operator_config |
否 |
String |
参数解释: 各算子并行度参数,以json的形式展示各算子id和并行度。 取值范围: 无 |
static_estimator_config |
否 |
String |
参数解释: 静态流图资源预估参数,以json的形式展示。 取值范围: 无 |
real_cu_number |
否 |
Integer |
参数解释: 实际使用的CU数。默认值为“0”,表示此时以“cu_number”的值为准。 取值范围: 无 |
请求示例
无
响应示例
{ "is_success": "true", "message": "作业列表查询成功", "job_list": { "total_count": 26, "jobs": [ { "job_id": 146, "name": "aaaaa", "desc": "", "user_name": "", "job_type": "flink_sql_job", "status": "job_init", "status_desc": "", "create_time": 1578892414688, "duration": 0, "root_id": -1, "graph_editor_enabled": false, "has_savepoint": false } ] } }
错误码
调用接口出错后,将不会返回上述结果,而是返回错误码和错误信息,更多介绍请参见错误码。