更新时间：2025-12-30 GMT+08:00
导入Flink作业保存点
功能介绍
导入Flink作业保存点。
授权信息
账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。
- 如果使用角色与策略授权，具体权限要求请参见权限及授权项说明。
- 如果使用身份策略授权，需具备如下身份策略权限。
授权项
Action
访问级别
Access Level
资源类型（*为必须）
Resource Type (*: required)
条件键
Condition Key
别名
Alias
依赖的授权项
Dependencies
dli:jobs:update
write
jobs *
-
-
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路径。 配置示例：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": bucket-name/dir/savepoint/"
} 响应示例
{
"is_success": true,
"message": "作业更新成功"
} 状态码
状态码 | 描述 |
|---|---|
200 | 修改成功。 |
400 | 请求错误。 |
500 | 内部服务器错误。 |
错误码
请参见错误码。
父主题：Flink作业管理相关API
