Importing Savepoints for Flink Jobs
Function
This API is used to import savepoints for Flink jobs.
URI
POST /v1.0/{project_id}/streaming/jobs/{job_id}/import-savepoint
| Parameter | Mandatory | Type | Description | 
|---|---|---|---|
| job_id | Yes | String | ID of a Flink job | 
| project_id | Yes | String | Project ID, which is used for resource isolation. For how to obtain a project ID, see Obtaining a Project ID. | 
Request Parameters
| Parameter | Mandatory | Type | Description | 
|---|---|---|---|
| job_id | Yes | Long | ID of a Flink job | 
| savepoint_path | Yes | String | Savepoint path Example: bucket-name/dir | 
Response Parameters
Status code: 200
| Parameter | Type | Description | 
|---|---|---|
| is_success | Boolean | Whether the request is successfully executed. true indicates that the request is successfully executed. | 
| message | String | System prompt. If the execution succeeds, this parameter may be left blank. | 
Status code: 400
| Parameter | Type | Description | 
|---|---|---|
| error_code | String | Error code | 
| error_msg | String | Error message | 
Status code: 500
| Parameter | Type | Description | 
|---|---|---|
| error_code | String | Error code | 
| error_msg | String | Error message | 
Example Request
{
 "job_id": 137228,
 "savepoint_path": bucket-name/dir/savepoint/"
}
 Example Response
{
    "is_success": true,
    "message": "The job is updated successfully.",
}
 Status Codes
| Status Code | Description | 
|---|---|
| 200 | The modification is successful. | 
| 400 | Request error. | 
| 500 | Internal server error. | 
Error Codes
See Error Codes.
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.
 
    