This is an automated email from the ASF dual-hosted git repository.
srichter pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 32f0ad7 [hotfix] Remove unused method
ExecutionGraph#restoreLatestCheckpointedState
32f0ad7 is described below
commit 32f0ad79be4b18774e1506db56ae59658ec211e1
Author: Stefan Richter <s.rich...@data-artisans.com>
AuthorDate: Mon Apr 15 17:28:02 2019 +0200
[hotfix] Remove unused method ExecutionGraph#restoreLatestCheckpointedState
---
.../flink/runtime/executiongraph/ExecutionGraph.java | 20 --------------------
1 file changed, 20 deletions(-)
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
index 5e44e94..56e31a3 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
@@ -1291,26 +1291,6 @@ public class ExecutionGraph implements
AccessExecutionGraph {
}
/**
- * 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}.
*
* @return ArchivedExecutionConfig which may be null in case of errors
