Skip to content

Commit

Permalink
[hotfix] Remove unused method ExecutionGraph#restoreLatestCheckpointe…
Browse files Browse the repository at this point in the history
…dState
  • Loading branch information
StefanRRichter committed Apr 15, 2019
1 parent f726468 commit 32f0ad7
Showing 1 changed file with 0 additions and 20 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1290,26 +1290,6 @@ public void restart(long expectedGlobalVersion) {
}
}

/**
* Restores the latest checkpointed state.
*
* <p>The recovery of checkpoints might block. Make sure that calls to this method don't
* block the job manager actor and run asynchronously.
*
* @param errorIfNoCheckpoint Fail if there is no checkpoint available
* @param allowNonRestoredState Allow to skip checkpoint state that cannot be mapped
* to the ExecutionGraph vertices (if the checkpoint contains state for a
* job vertex that is not part of this ExecutionGraph).
*/
public void restoreLatestCheckpointedState(boolean errorIfNoCheckpoint, boolean allowNonRestoredState) throws Exception {
assertRunningInJobMasterMainThread();
synchronized (progressLock) {
if (checkpointCoordinator != null) {
checkpointCoordinator.restoreLatestCheckpointedState(getAllVertices(), errorIfNoCheckpoint, allowNonRestoredState);
}
}
}

/**
* Returns the serializable {@link ArchivedExecutionConfig}.
*
Expand Down

0 comments on commit 32f0ad7

Please sign in to comment.