Skip to main content

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.

warning

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.

note

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.

note

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

  1. 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).
  2. In Ververica Platform 3, create a new deployment using an artifact that is compatible with the Ververica Platform 2 job's state schema.
  3. Load the Ververica Platform 2 savepoint path using either the Kubernetes Operator approach or the API approach described above.
  4. Start the deployment. It resumes from the state captured in Ververica Platform 2.

Troubleshooting

ProblemLikely causeResolution
Savepoint stays in PENDINGThe URI is unreachable or incorrectly formattedVerify the path and confirm the Ververica Platform pod has read access to the storage location.
Deployment fails on startThe savepoint is incompatible with the jobConfirm the artifact is state-compatible with the savepoint. Operator and schema changes between VVP versions can cause restore failures.
initialSavepointSpec has no effectThe deployment already existsThis field is applied only when the deployment is first created. Delete the deployment and apply the CR again.