更新Flink Jar作业
功能介绍
该API用于更新用户自定义作业，目前仅支持Jar格式，运行在独享队列中。
URI
- URI格式
- 参数说明
表1 URI参数说明 参数名称
是否必选
参数类型
说明
project_id
是
String
项目编号，用于资源隔离。获取方式请参考获取项目ID。
job_id
是
Long
作业ID。具体可以从新建Flink Jar作业中获取。
请求消息
|
参数名称 |
是否必选 |
参数类型 |
说明 |
|---|---|---|---|
|
name |
否 |
String |
作业名称。长度限制：0-57个字符。 |
|
desc |
否 |
String |
作业描述。长度限制：0-512个字符。 |
|
queue_name |
否 |
String |
队列名称。长度限制：1-128个字符。 |
|
cu_number |
否 |
Integer |
用户为作业选择的CU数量。默认值为“2”。 |
|
manager_cu_number |
否 |
Integer |
用户为作业选择的管理节点CU数量，对应为flink jobmanager数量。默认值为“1”。 |
|
parallel_number |
否 |
Integer |
用户为作业选择的并发量。默认值为“1”。 |
|
log_enabled |
否 |
Boolean |
是否开启作业日志。
|
|
obs_bucket |
否 |
String |
当“log_enabled”为“true”时，用户授权保存日志的OBS路。 |
|
smn_topic |
否 |
String |
当作业异常时，向该SMN主题推送告警信息。 |
|
main_class |
否 |
String |
作业入口类。 |
|
entrypoint_args |
否 |
String |
作业入口类参数，多个参数之间空格分隔。 |
|
restart_when_exception |
否 |
Boolean |
是否开启异常重启功能，默认值为“false”。 |
|
entrypoint |
否 |
String |
用户已上传到DLI资源管理系统的程序包名，用户自定义作业主类所在的jar包。 |
|
dependency_jars |
否 |
Array of Strings |
用户已上传到DLI资源管理系统的程序包名，用户自定义作业的其他依赖包。 示例“myGroup/test.jar,myGroup/test1.jar”。 |
|
dependency_files |
否 |
Array of Strings |
用户已上传到DLI资源管理系统的资源包名，用户自定义作业的依赖文件。 示例："myGroup/test.cvs,myGroup/test1.csv" |
|
tm_cus |
否 |
Integer |
每个taskmanager的CU数，默认值为“1”。 |
|
tm_slot_num |
否 |
Integer |
每个taskmanager的slot数，默认值为“(parallel_number*tm_cus)/(cu_number-manager_cu_number)”。 |
|
resume_checkpoint |
否 |
Boolean |
异常重启是否从checkpoint恢复。 |
|
resume_max_num |
否 |
Integer |
异常重试最大次数，单位：次/小时。取值范围：-1或大于0。默认值为“-1”，表示无限次数。 |
|
checkpoint_path |
否 |
String |
用户Jar中checkpoint的储存地址，不同作业路径需要保持不同。 |
|
runtime_config |
否 |
String |
Flink作业运行时自定义优化参数。 |
|
job_type |
否 |
String |
作业类型。 |
响应消息
|
参数名称 |
是否必选 |
参数类型 |
说明 |
|---|---|---|---|
|
is_success |
否 |
Boolean |
执行请求是否成功。“true”表示请求执行成功。 |
|
message |
否 |
String |
消息内容。 |
|
job |
否 |
object |
作业更新信息。具体请参考表4。 |
请求示例
{
"name": "test1",
"desc": "job for test",
"job_type": "flink_jar_job",
"queue_name": "testQueue",
"manager_cu_number": 1,
"cu_number": 2,
"parallel_number": 1,
"log_enabled": false,
"main_class": "org.apache.flink.examples.streaming.JavaQueueStream",
"restart_when_exception": false,
"entrypoint": "FemaleInfoCollec.jar",
"dependency_jars": [
"myGroup/test.jar",
"myGroup/test1.jar"
],
"dependency_files": [
"myGroup/test.csv",
"myGroup/test1.csv"
]
}
响应示例
{
"is_success": true,
"message": "更新flink作业成功",
"job": {
"update_time": 1516952770835
}
}
错误码
调用接口出错后，将不会返回上述结果，而是返回错误码和错误信息，更多介绍请参见错误码。
