From 32f0ad79be4b18774e1506db56ae59658ec211e1 Mon Sep 17 00:00:00 2001 From: Stefan Richter Date: Mon, 15 Apr 2019 17:28:02 +0200 Subject: [PATCH] [hotfix] Remove unused method ExecutionGraph#restoreLatestCheckpointedState --- .../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 5e44e94eab846..56e31a3f1dde6 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 @@ -1290,26 +1290,6 @@ public void restart(long expectedGlobalVersion) { } } - /** - * Restores the latest checkpointed state. - * - *

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}. *