更新时间:2024-10-31 GMT+08:00

导入Flink作业保存点

功能介绍

导入Flink作业保存点。

URI

POST /v1.0/{project_id}/streaming/jobs/{job_id}/import-savepoint

表1 路径参数

参数

是否必选

参数类型

描述

job_id

String

Flink作业的作业ID。

project_id

String

项目编号,用于资源隔离。获取方式请参考获取项目ID

请求参数

表2 请求Body参数

参数

是否必选

参数类型

描述

job_id

Long

Flink作业的ID。

savepoint_path

String

Savepoint路径。

配置示例:obs://bucket-name/dir

响应参数

状态码: 200

表3 响应Body参数

参数名称

参数类型

说明

is_success

Boolean

执行请求是否成功。“true”表示请求执行成功。

message

String

系统提示信息,执行成功时,信息可能为空。

状态码: 400

表4 响应Body参数

参数

参数类型

描述

error_code

String

错误码。

error_msg

String

错误描述信息。

状态码: 500

表5 响应Body参数

参数

参数类型

描述

error_code

String

错误码。

error_msg

String

错误描述信息。

请求示例

{
 "job_id": 137228,
 "savepoint_path": "obs://bucket-name/dir/savepoint/"
}

响应示例

{
    "is_success": true,
    "message": "作业更新成功"
}

状态码

状态码

描述

200

修改成功。

400

请求错误。

500

内部服务器错误。

错误码

请参见错误码