public class SavepointLoader extends Object
Modifier and Type | Method and Description |
---|---|
static CompletedCheckpoint |
loadAndValidateSavepoint(JobID jobId,
Map<JobVertexID,ExecutionJobVertex> tasks,
String savepointPath,
ClassLoader userClassLoader,
boolean allowNonRestoredState)
Loads a savepoint back as a
CompletedCheckpoint . |
public static CompletedCheckpoint loadAndValidateSavepoint(JobID jobId, Map<JobVertexID,ExecutionJobVertex> tasks, String savepointPath, ClassLoader userClassLoader, 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 touserClassLoader
- The user code classloaderallowNonRestoredState
- Allow to skip checkpoint state that cannot be mapped
to any job vertex in tasks.IllegalStateException
- If mismatch between program and savepoint stateException
- If savepoint store failureIOException
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.