文档首页/ MapReduce服务 MRS/ API参考（安卡拉区域）/ API V2/ 作业管理接口/ 查询单个作业信息
更新时间：2024-11-29 GMT+08:00
查看PDF
分享

查询单个作业信息

功能介绍

在MRS集群中查询指定作业的详细信息。

URI

  • URI格式

    GET /v2/{project_id}/clusters/{cluster_id}/job-executions/{job_execution_id}

  • 参数说明
    表1 URI参数说明

    名称

    是否必选

    参数类型

    说明

    project_id

    是

    String

    参数解释：

    项目编号。获取方法，请参见获取项目ID。

    约束限制：

    不涉及

    取值范围：

    只能由英文字母和数字组成，且长度为[1-64]个字符。

    默认取值：

    不涉及

    cluster_id

    是

    String

    参数解释：

    集群ID。如果指定集群ID，则获取该集群做过补丁更新的最新版本元数据。获取方法，请参见获取集群ID。

    约束限制：

    不涉及

    取值范围：

    只能由英文字母、数字以及“_”和“-”组成，且长度为[1-64]个字符。

    默认取值：

    不涉及

    job_execution_id

    是

    String

    参数解释：

    作业ID。获取方法，请参见获取作业ID。

    约束限制：

    不涉及

    取值范围：

    不涉及

    默认取值：

    不涉及

请求参数

无。

响应参数

状态码：202

表2 响应参数说明

参数名

参数类型

说明

job_detail

JobQueryBean object

参数解释：

作业详细信息，具体参数说明请参考表3。
表3 作业信息参数说明

参数名

参数类型

说明

job_id

String

参数解释：

作业ID。

取值范围：

不涉及

user

String

参数解释：

提交作业的用户名称。

取值范围：

不涉及

job_name

String

参数解释：

作业名称。

取值范围：

不涉及

job_result

String

参数解释：

作业最终结果。

取值范围：

  • FAILED：执行失败的作业。
  • KILLED：执行中被手动终止的作业。
  • UNDEFINED：正在执行的作业。
  • SUCCEEDED：执行成功的作业。

job_state

String

参数解释：

作业执行状态。

取值范围：

  • FAILED：失败
  • KILLED：已终止
  • NEW：已创建
  • NEW_SAVING：已创建保存中
  • SUBMITTED：已提交
  • ACCEPTED：已接受
  • RUNNING：运行中
  • FINISHED：已完成

job_progress

Float

参数解释：

作业执行进度。

取值范围：

不涉及

job_type

String

参数解释：

作业类型。

取值范围：

  • MapReduce
  • SparkSubmit：SparkPython类型的作业在查询时作业类型请选择SparkSubmit。
  • HiveScript
  • HiveSql
  • DistCp：导入、导出数据。
  • SparkScript
  • SparkSql
  • Flink

started_time

Long

参数解释：

作业开始执行时间。单位：毫秒。

取值范围：

不涉及

submitted_time

Long

参数解释：

作业提交时间。单位：毫秒。

取值范围：

不涉及

finished_time

Long

参数解释：

作业完成时间。单位：毫秒。

取值范围：

不涉及

elapsed_time

Long

参数解释：

作业执行时长。单位：毫秒。

取值范围：

不涉及

arguments

String

参数解释：

运行参数。

取值范围：

不涉及

properties

String

参数解释：

配置参数，用于传-d参数。

取值范围：

不涉及

launcher_id

String

参数解释：

真实作业编号。

取值范围：

不涉及

app_id

String

参数解释：

实际作业编号。

取值范围：

不涉及

tracking_url

String

参数解释：

日志链接地址。当前仅SparkSubmit作业支持该参数。该参数基于集群的EIP访问集群中的Yarn WebUI页面，用户如果在VPC界面解绑EIP，MRS服务侧数据会因为未更新导致该参数引用旧EIP导致访问失败，可通过对集群重新绑定EIP来修复该问题。

取值范围：

不涉及

queue

String

参数解释：

作业的资源队列类型。

取值范围：

不涉及

状态码：500

表4 响应Body参数

参数

参数类型

描述

error_code

String

参数解释：

错误码。

取值范围：

不涉及

error_msg

String

参数解释：

错误描述。

取值范围：

不涉及

请求示例

查询单个作业请求示例

GET https://{endpoint}/v2/{project_id}/clusters/{cluster_id}/job-executions/{job_execution_id}

响应示例

状态码： 202

查询单个作业信息成功

{
  "job_detail" : {
    "job_id" : "431b135e-c090-489f-b1db-0abe3822b855",
    "user" : "xxxx",
    "job_name" : "pyspark1",
    "job_result" : "SUCCEEDED",
    "job_state" : "FINISHED",
    "job_progress" : 100,
    "job_type" : "SparkSubmit",
    "started_time" : 1564626578817,
    "submitted_time" : 1564626561541,
    "finished_time" : 1564626664930,
    "elapsed_time" : 86113,
    "queue" : "default",
    "arguments" : "[--class, org.apache.spark.examples.SparkPi, --driver-memory, 512MB, --num-executors, 1, --executor-cores, 1, --master, yarn-cluster, s3a://obs-test/jobs/spark/spark-examples_2.11-2.1.0.jar, 10000]",
    "launcher_id" : "application_1564622673393_0006",
    "app_id" : "application_1564622673393_0007",
    "properties" : "{}"
  }
}

状态码： 400

查询单个作业信息失败

{
  "error_msg" : "查询作业失败",
  "error_code" : "0162"
}

状态码

状态码请参见状态码。

错误码

请参见错误码。

父主题： 作业管理接口