更新时间:2024-10-31 GMT+08:00
导入Flink作业保存点
功能介绍
导入Flink作业保存点。
URI
POST /v1.0/{project_id}/streaming/jobs/{job_id}/import-savepoint
参数 |
是否必选 |
参数类型 |
描述 |
---|---|---|---|
job_id |
是 |
String |
Flink作业的作业ID。 |
project_id |
是 |
String |
项目编号,用于资源隔离。获取方式请参考获取项目ID。 |
请求参数
参数 |
是否必选 |
参数类型 |
描述 |
---|---|---|---|
job_id |
是 |
Long |
Flink作业的ID。 |
savepoint_path |
是 |
String |
Savepoint路径。 配置示例:obs://bucket-name/dir |
响应参数
状态码: 200
参数名称 |
参数类型 |
说明 |
---|---|---|
is_success |
Boolean |
执行请求是否成功。“true”表示请求执行成功。 |
message |
String |
系统提示信息,执行成功时,信息可能为空。 |
状态码: 400
参数 |
参数类型 |
描述 |
---|---|---|
error_code |
String |
错误码。 |
error_msg |
String |
错误描述信息。 |
状态码: 500
参数 |
参数类型 |
描述 |
---|---|---|
error_code |
String |
错误码。 |
error_msg |
String |
错误描述信息。 |
请求示例
{ "job_id": 137228, "savepoint_path": "obs://bucket-name/dir/savepoint/" }
响应示例
{ "is_success": true, "message": "作业更新成功" }
状态码
状态码 |
描述 |
---|---|
200 |
修改成功。 |
400 |
请求错误。 |
500 |
内部服务器错误。 |
错误码
请参见错误码。
父主题: Flink作业管理相关API