Load a Savepoint from a Custom Location
Ververica Platform lets you start a deployment from a savepoint stored at any accessible storage location, not only savepoints managed within the platform. Use this when restoring state from an external source, such as a savepoint taken from a Ververica Platform 2 deployment.
Load Using the Kubernetes Operator
The Kubernetes Operator supports loading from a custom savepoint location through the spec.initialSavepointSpec.savepointLocation field. This requires two sequential kubectl apply operations.
Step 1: Register the Savepoint
Apply a CR that sets the deployment state to CANCELLED and includes initialSavepointSpec:
apiVersion: ververica.platform/v1
kind: VvpDeployment
metadata:
name: my-deployment
namespace: vvp-system
spec:
syncingMode: PATCH
initialSavepointSpec:
savepointLocation: s3://my-bucket/savepoints/savepoint-abc123
deployment:
userMetadata:
name: my-deployment
namespace: default
displayName: my-deployment
spec:
state: CANCELLED
deploymentTargetName: my-target
template:
spec:
artifact:
jarUri: file:///opt/flink/examples/streaming/MyJob.jar
kind: JAR
Wait until the savepoint appears in the deployment's state history with status COMPLETED.
Step 2: Start the Deployment
Apply a second CR with state: RUNNING. Omit initialSavepointSpec in this step:
apiVersion: ververica.platform/v1
kind: VvpDeployment
metadata:
name: my-deployment
namespace: vvp-system
spec:
syncingMode: PATCH
deployment:
userMetadata:
name: my-deployment
namespace: default
displayName: my-deployment
spec:
state: RUNNING
deploymentTargetName: my-target
template:
spec:
artifact:
jarUri: file:///opt/flink/examples/streaming/MyJob.jar
kind: JAR
The deployment starts and restores state from the savepoint.
initialSavepointSpec is only applied when the deployment does not yet exist. Remove it from the CR after the deployment is created. If left in place and the deployment is later cancelled and recreated, the operator references the original savepoint again, overwriting any newer savepoints.
restoreStrategy must not be set to NONE. The default value LATEST_STATE is compatible with this approach.
Load Using the API
If you are not using the Kubernetes Operator, you can load a savepoint from a custom location by submitting a job through the REST API and setting restoreStrategy.kind to USER_DEFINED_STATE.
Prerequisites
- You have a savepoint from your Ververica Platform 2 deployment and know its full storage path. For instructions on creating a savepoint, see Savepoints.
- The savepoint path is accessible from the Ververica Platform 3 deployment (same storage backend and authentication).
Submit the Job
Send a POST request to the jobs start endpoint, passing the USER_DEFINED_STATE restore strategy with the savepoint path as statePath:
curl -X POST 'https://app.ververica.cloud/api/v2/namespaces/{namespace}/jobs:start' \
-H 'authorization: Bearer {token}' \
-H 'accept: application/json' \
-H 'workspace: {workspace-id}' \
-H 'Content-Type: application/json' \
-d '{
"deploymentId": "{deployment-id}",
"restoreStrategy": {
"kind": "USER_DEFINED_STATE",
"statePath": "{savepoint-path}",
"allowNonRestoredState": false
},
"localVariables": []
}'
Replace {namespace}, {token}, {workspace-id}, {deployment-id}, and {savepoint-path} with your values.
This option is not yet available in the UI. Use the API directly as shown above.
Example: Migrate State from Ververica Platform 2 to Ververica Platform 3
- In Ververica Platform 2, trigger a savepoint on the running deployment and record the savepoint path (for example,
s3://my-bucket/vvp2-jobs/namespaces/ns/jobs/abc123/savepoints/savepoint-xyz). - In Ververica Platform 3, create a new deployment using an artifact that is compatible with the Ververica Platform 2 job's state schema.
- Load the Ververica Platform 2 savepoint path using either the Kubernetes Operator approach or the API approach described above.
- Start the deployment. It resumes from the state captured in Ververica Platform 2.
Troubleshooting
| Problem | Likely cause | Resolution |
|---|---|---|
| Savepoint stays in PENDING | The URI is unreachable or incorrectly formatted | Verify the path and confirm the Ververica Platform pod has read access to the storage location. |
| Deployment fails on start | The savepoint is incompatible with the job | Confirm the artifact is state-compatible with the savepoint. Operator and schema changes between VVP versions can cause restore failures. |
initialSavepointSpec has no effect | The deployment already exists | This field is applied only when the deployment is first created. Delete the deployment and apply the CR again. |