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.