更新时间:2025-08-06 GMT+08:00

查询作业列表

功能介绍

查询当前用户的作业列表,可以根据作业ID作为ID,查询大于ID或小于ID的限定条数的作业,默认查询全部状态的作业,也可以设定运行中或其他状态条件。

URI

  • URI格式

    GET /v1.0/{project_id}/streaming/jobs

  • 参数说明
    表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

    参数解释:

    指定标签过滤。

    约束限制:

    取值范围:

    默认取值:

请求消息

无请求参数。

响应消息

表3 响应参数说明

参数名称

是否必选

参数类型

说明

is_success

String

参数解释:

执行请求是否成功。

取值范围:

“true”:表示请求执行成功。

“false”:表示请求执行失败。

message

String

参数解释:

系统提示信息,执行成功时,该值为空。

取值范围:

job_list

Object

参数解释:

作业列表信息。请参见表4

取值范围:

表4 job_list参数说明

参数名称

是否必选

参数类型

说明

total_count

Integer

参数解释:

作业查询结果条数。

取值范围:

jobs

Array of Objects

参数解释:

作业信息。请参见表5

取值范围:

表5 Jobs参数说明

参数名称

是否必选

参数类型

说明

job_id

Long

参数解释:

作业ID。

取值范围:

name

String

参数解释:

作业名称。

取值范围:

长度限制:0-57个字符。

desc

String

参数解释:

作业描述。

取值范围:

长度限制:0-512个字符。

user_name

String

参数解释:

用户名,当“show_detail”“false”时独有。

取值范围:

长度在[1,128]范围内的字符串

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:已完成

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”时独有。

取值范围:

  • shared_cluster:共享
  • exclusive_cluster:独享
  • edge_node:边缘节点

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的保存路径。

取值范围:

表6 job_config参数说明

参数名称

是否必选

参数类型

说明

checkpoint_enabled

Boolean

参数解释:

是否开启作业自动快照功能。

取值范围:

  • true:开启
  • false:关闭

默认为“false”

checkpoint_mode

String

参数解释:

快照模式,。

取值范围:

两种可选:

  • exactly_once:数据只被消费一次。
  • at_least_once:数据至少被消费一次。

默认值为“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
  • 最大值:400

默认为“2”

取值范围:

parallel_number

Integer

参数解释:

用户设置的作业并行数。 “show_detail”“true”时独有。

  • 最小值:1
  • 最大值:2000

默认为“1”

取值范围:

restart_when_exception

Boolean

参数解释:

是否开启异常重启功能。

取值范围:

idle_state_retention

Integer

参数解释:

空闲状态过期周期。

取值范围:

udf_jar_url

String

参数解释:

用户已上传到DLI资源管理系统的程序包名,用户sql作业的udf jar通过该参数传入。

取值范围:

dirty_data_strategy

String

参数解释:

作业脏数据策略。

取值范围:

  • “2:obsDir”:保存,obsDir表示脏数据存储路径。
  • “1”:抛出异常。
  • “0”:忽略。

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镜像类型。

取值范围:

  • basic:表示使用DLI提供的基础Flink镜像。
  • custom:表示使用用户自定义的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
            }
        ]
    }
}

状态码

状态码如表7所示。

表7 状态码

状态码

描述

200

查询作业列表成功。

400

输入参数无效。

错误码

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