更新时间：2022-12-14 GMT+08:00
执行作业对象
功能介绍
执行创建的作业对象。该接口兼容Sahara。
URI
- URI格式
- 参数说明
表1 URI参数说明 名称
是否必选
说明
project_id
是
项目编号。获取方法，请参见获取项目ID。
job_id
是
作业对象ID。
请求消息
|
名称 |
是否必选 |
参数类型 |
说明 |
|---|---|---|---|
|
cluster_id |
是 |
String |
集群ID。 |
|
input_id |
是 |
String |
作业对象输入数据源ID。获取方法，请参见创建数据源。 |
|
output_id |
是 |
String |
作业对象输出数据源ID。获取方法，请参见创建数据源。 |
|
is_protected |
否 |
Bool |
作业对象是否受保护。
当前版本不支持该功能。 |
|
is_public |
否 |
Bool |
作业对象是否公开。
当前版本不支持该功能。 |
|
job_configs |
是 |
Object |
键值对集合，用于保存作业运行配置。 当作业类型为MapReduce和Spark时，第一个参数args的设置同argument，详情请参见新增作业并执行（废弃）。 |
响应消息
|
名称 |
参数类型 |
说明 |
|---|---|---|
|
output_id |
String |
作业对象输出数据源ID。 |
|
info |
Object |
作业对象状态信息。 |
|
job_id |
String |
作业对象ID。 |
|
tenant_id |
String |
项目编号。获取方法，请参见获取项目ID。 |
|
created_at |
String |
作业对象创建时间。 |
|
updated_at |
String |
作业对象更新时间。 |
|
return_code |
String |
作业执行后的响应码。 |
|
oozie_job_id |
String |
集群中oozie返回的工作流ID。 |
|
is_protected |
Bool |
作业对象是否受保护。
当前版本不支持该功能。 |
|
input_id |
String |
作业对象输入数据源ID。 |
|
cluster_id |
String |
集群ID。 |
|
is_public |
Bool |
作业对象是否公开。
当前版本不支持该功能。 |
|
job_configs |
Object |
键值对集合，用于保存作业运行配置。 |
|
id |
String |
作业对象ID。 |
示例
- 请求示例
The request example of MapReduce job: { "cluster_id": "811e1134-666f-4c48-bc92-afb5b10c9d8c", "input_id": "3e1bc8e6-8c69-4749-8e52-90d9341d15bc", "output_id": "52146b52-6540-4aac-a024-fee253cf52a9", "is_protected": false, "is_public": false, "job_configs": { "configs": { "mapred.map.tasks": "1", "mapred.reduce.tasks": "1" }, "args": [ "wordcount", "arg2" ], "params": { "param2": "value2", "param1": "value1" } } } The request example of Spark job: { "cluster_id": "8f3a547d-d53a-44ba-9aad-ded0b0b26e9c", "input_id": "3e1bc8e6-8c69-4749-8e52-90d9341d15bc", "output_id": "8bb0259f-309a-49f4-843b-0be86ac1623a", "job_configs": { "configs": { }, "args": [ "org.apache.spark.examples.SparkPi 10", "arg2" ], "params": { "param2": "value2", "param1": "value1" } } } The request example of DistCp job: { "cluster_id": "811e1134-666f-4c48-bc92-afb5b10c9d8c", "input_id": "3e1bc8e6-8c69-4749-8e52-90d9341d15bc", "output_id": "52146b52-6540-4aac-a024-fee253cf52a9", "is_protected": false, "is_public": false, "job_configs": { "configs": { }, "args": [ "arg1", "arg2" ], "params": { "param2": "value2", "param1": "value1" } } } The request example of Hive job: { "cluster_id": "8f3a547d-d53a-44ba-9aad-ded0b0b26e9c", "input_id": "3e1bc8e6-8c69-4749-8e52-90d9341d15bc", "output_id": "8bb0259f-309a-49f4-843b-0be86ac1623a", "is_protected": false, "is_public": false, "job_configs": { "configs": { }, "args": [ "arg1", "arg2" ], "params": { "param2": "value2", "param1": "value1" } } } The request example of SparkScript job: { "cluster_id": "811e1134-666f-4c48-bc92-afb5b10c9d8c", "input_id": "3e1bc8e6-8c69-4749-8e52-90d9341d15bc", "output_id": "52146b52-6540-4aac-a024-fee253cf52a9", "is_protected": false, "is_public": false, "job_configs": { "configs": { }, "args": [ "arg1", "arg2" ], "params": { "param2": "value2", "param1": "value1" } } } - 响应示例
{ "job_execution":{ "created_at":"2017-02-20T09:11:32", "updated_at":"2017-02-20T09:11:32", "id":"4a56525d-34db-43e3-99c9-af67491025cd", "tenant_id":"3f99e3319a8943ceb15c584f3325d064", "job_id":"2c12ff33-da22-47b1-b51f-2828c16bbad8", "start_time":"2017-02-20T09:11:32", "end_time":null, "cluster_id":"c1000b4f-f2a1-49e1-af3c-2e19fc1eb72d", "oozie_job_id":null, "return_code":null, "input_id":"ce8c2b04-f46c-4580-8b58-5b6aaf4a44a9", "output_id":"9d59ce5b-d0f4-46d4-8738-6e50c2a5c68a", "is_protected":null, "is_public":null, "job_configs":{ "configs":{ "mapred.map.tasks":"1", "mapred.reduce.tasks":"1" }, "args":[ "wordcount ", "arg2" ], "params":{ "param2":"value2", "param1":"value1" } }, "data_source_urls":null, "info":null } }
父主题： 作业对象接口
