新增作业并执行（废弃）

project_id

是

String

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

job_name

是

String

作业名称，只能由字母、数字、中划线和下划线组成，并且长度为1～64个字符。

说明： 不同作业的名称允许相同，但不建议设置相同。

cluster_id

是

String

集群ID。

jar_path

否

String

执行程序Jar包或sql文件地址，需要满足如下要求：

• 最多为1023字符，不能包含;|&><'$特殊字符，且不可为空或全空格。
• 需要以“/”或“s3a://”开头。OBS路径不支持KMS加密的文件或程序。
• Spark Script需要以“.sql”结尾，MapReduce和Spark Jar需要以“.jar”结尾，sql和jar不区分大小写。

说明： 作业类型为MapReduce或Spark时，jar_path参数为必选。

input

否

String

数据输入地址，必须以“/”或“s3a://”开头。请配置为正确的OBS路径，OBS路径不支持KMS加密的文件或程序。

最多为1023字符，不能包含;|&>'<$特殊字符，可为空。

output

否

String

数据输出地址，必须以“/”或“s3a://”开头。请配置为正确的OBS路径，如果该路径不存在，系统会自动创建。

最多为1023字符，不能包含;|&>'<$特殊字符，可为空。

job_log

否

String

作业日志存储地址，该日志信息记录作业运行状态。必须以“/”或“s3a://”开头，请配置为正确的OBS路径。

最多为1023字符，不能包含;|&>'<$特殊字符，可为空。

job_type

是

Integer

作业类型码。

• 1：MapReduce
• 2：Spark
• 3：Hive Script
• 4：HiveSQL（当前不支持）
• 5：DistCp，导入、导出数据。
• 6：Spark Script
• 7：Spark SQL，提交SQL语句（该接口当前不支持）

file_action

否

String

文件操作类型，包括： export：从HDFS导出数据至OBS import：从OBS导入数据至HDFS

arguments

否

String

程序执行的关键参数，该参数由用户程序内的函数指定，MRS只负责参数的传入。 最多为150000字符，不能包含;|&>'<$!"\特殊字符，可为空。 说明： 用户输入带有敏感信息（如登录密码）的参数时，可通过在参数名前添加“@”的方式，为该参数值加密，以防止敏感信息被明文形式持久化。在查看作业信息时，敏感信息显示为“*”。 例如：username=xxx @password=yyy

hql

否

String

Spark SQL语句，该语句需要进行Base64编码和解码，“ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/”为标准的编码表，MRS使用“ABCDEFGHILKJMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/”进行Base64编码。在编码后所得字符串首位任意加上一个字母，即得到Hql参数的值。后台自动进行解码得到Spark SQL语句。 使用样例：

1. 在Web界面输入Spark SQL语句“show tables;”。
2. 使用“ABCDEFGHILKJMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/”编码后得到字符串“c2hvdyB0YWLsZXM7”。
3. 在“c2hvdyB0YWLsZXM7”首位任意加上一字母，例如“gc2hvdyB0YWLsZXM7”，即Hql参数的值。
4. 后台自动进行解码得到Spark SQL语句“show tables;”。

hive_script_path

否

String

sql程序路径，仅Spark Script和Hive Script作业需要使用此参数。需要满足如下要求：

• 最多为1023字符，不能包含;|&><'$特殊字符，且不可为空或全空格。
• 需要以“/”或“s3a://”开头，OBS路径不支持KMS加密的文件或程序。
• 需要以“.sql”结尾，sql不区分大小写。

templated

Boolean

作业执行对象是否由作业模板生成。

created_at

Long

作业创建时间，十位时间戳。

updated_at

Long

作业更新时间，十位时间戳。

id

String

作业ID。

tenant_id

String

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

job_id

String

作业应用ID。

job_name

String

作业名称，只能由字母、数字、中划线和下划线组成，并且长度为1～64个字符。

说明： 不同作业的名称允许相同，但不建议设置相同。

input_id

String

数据输入ID。

output_id

String

数据输出ID。

start_time

Long

作业执行开始时间，十位时间戳。

end_time

Long

作业执行结束时间，十位时间戳。

cluster_id

String

集群ID。

engine_job_id

String

Oozie工作流ID。

return_code

String

运行结果返回码。

is_public

Boolean

是否公开。 当前版本不支持该功能。

is_protected

Boolean

是否受保护。 当前版本不支持该功能。

group_id

String

作业执行组ID。

jar_path

String

执行程序Jar包或sql文件地址，需要满足如下要求：

• 最多为1023字符，不能包含;|&><'$特殊字符，且不可为空或全空格。
• 需要以“/”或“s3a://”开头。OBS路径不支持KMS加密的文件或程序。
• Spark Script需要以“.sql”结尾，MapReduce和Spark Jar需要以“.jar”结尾，sql和jar不区分大小写。

input

String

数据输入地址，必须以“/”或“s3a://”开头。请配置为正确的OBS路径，OBS路径不支持KMS加密的文件或程序。

最多为1023字符，不能包含;|&>'<$特殊字符，可为空。

output

String

数据输出地址，必须以“/”或“s3a://”开头。请配置为正确的OBS路径，如果该路径不存在，系统会自动创建。

最多为1023字符，不能包含;|&>'<$特殊字符，可为空。

job_log

String

作业日志存储地址，该日志信息记录作业运行状态。必须以“/”或“s3a://”开头，请配置为正确的OBS路径。

最多为1023字符，不能包含;|&>'<$特殊字符，可为空。

job_type

Integer

作业类型码。

• 1：MapReduce
• 2：Spark
• 3：Hive Script
• 4：HiveSQL（当前不支持）
• 5：DistCp，导入、导出数据。
• 6：Spark Script
• 7：Spark SQL，提交SQL语句，（该接口当前不支持）

说明： 只有包含Spark和Hive组件的集群才能新增Spark和Hive类型的作业。

file_action

String

文件操作类型，包括： - export：从HDFS导出数据至OBS - import：从OBS导入数据至HDFS

arguments

String

程序执行的关键参数，该参数由用户程序内的函数指定，MRS只负责参数的传入。 最多为150000字符，不能包含;|&>'<$!"\特殊字符，可为空。 说明： 用户输入带有敏感信息（如登录密码）的参数时，可通过在参数名前添加“@”的方式，为该参数值加密，以防止敏感信息被明文形式持久化。在查看作业信息时，敏感信息显示为“*”。 例如：username=admin @password=***

hql

String

Hive&Spark Sql语句

job_state

Integer

作业状态码。

• -1：Terminated
• 1：Starting
• 2：Running
• 3：Completed
• 4：Abnormal
• 5：Error

job_final_status

Integer

作业最终状态码。

• 0：未完成
• 1：执行错误，终止执行
• 2：执行完成并且成功
• 3：已取消

hive_script_path

String

sql程序路径，仅Spark Script和Hive Script作业需要使用此参数。需要满足如下要求：

• 最多为1023字符，不能包含;|&><'$特殊字符，且不可为空或全空格。
• 需要以“/”或“s3a://”开头，OBS路径不支持KMS加密的文件或程序。
• 需要以“.sql”结尾，sql不区分大小写。

create_by

String

创建作业的用户ID。

为兼容历史版本，保留此参数。

finished_step

Integer

当前已完成的步骤数。

为兼容历史版本，保留此参数。

job_main_id

String

作业主ID。

为兼容历史版本，保留此参数。

job_step_id

String

作业步骤ID。

为兼容历史版本，保留此参数。

postpone_at

Long

延迟时间，十位时间戳。

为兼容历史版本，保留此参数。

step_name

String

作业步骤名。

为兼容历史版本，保留此参数。

step_num

Integer

步骤数量

为兼容历史版本，保留此参数。

task_num

Integer

任务数量。 为兼容历史版本，保留此参数。

update_by

String

更新作业的用户ID。

credentials

String

令牌，当前版本不支持。

user_id

String

创建作业的用户ID。

历史版本兼容，不再使用。

job_configs

Map<String,Object>

键值对集合，用于保存作业运行配置。

extra

Map<String,Object>

认证信息，当前版本不支持。

data_source_urls

Map<String,Object>

数据源URL。

info

Map<String,Object>

键值对集合，包含oozie返回的作业运行信息。

200

新增作业成功。