public class SavepointLoader extends Object
Modifier and Type | Method and Description |
---|---|
static CompletedCheckpoint |
loadAndValidateSavepoint(JobID jobId,
Map<JobVertexID,ExecutionJobVertex> tasks,
String savepointPath,
ClassLoader classLoader,
boolean allowNonRestoredState)
Loads a savepoint back as a
CompletedCheckpoint . |
public static CompletedCheckpoint loadAndValidateSavepoint(JobID jobId, Map<JobVertexID,ExecutionJobVertex> tasks, String savepointPath, ClassLoader classLoader, boolean allowNonRestoredState) throws IOException
CompletedCheckpoint
.
This method verifies that tasks and parallelism still match the savepoint parameters.
jobId
- The JobID of the job to load the savepoint for.tasks
- Tasks that will possibly be resetsavepointPath
- The path of the savepoint to rollback toclassLoader
- The class loader to resolve serialized classes in legacy savepoint versions.allowNonRestoredState
- Allow to skip checkpoint state that cannot be mapped
to any job vertex in tasks.IllegalStateException
- If mismatch between program and savepoint stateIOException
- If savepoint store failureCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.