You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ro...@apache.org on 2021/12/09 16:01:13 UTC
[flink] branch master updated (7641c23 -> 718609d)
This is an automated email from the ASF dual-hosted git repository.
roman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 7641c23 [FLINK-25155] Support claim mode in rest api
add 718609d [FLINK-24086][checkpoint] Rebuild SharedStateRegistry only when the restore method is called for the first time
No new revisions were added by this update.
Summary of changes:
.../KubernetesCheckpointRecoveryFactory.java | 14 ++-
.../flink/kubernetes/utils/KubernetesUtils.java | 14 ++-
...y.java => AbstractCompleteCheckpointStore.java} | 30 ++++--
.../runtime/checkpoint/CheckpointCoordinator.java | 36 ++-----
.../checkpoint/CheckpointRecoveryFactory.java | 13 ++-
.../checkpoint/CompletedCheckpointStore.java | 4 +
...ctivatedCheckpointCompletedCheckpointStore.java | 6 ++
.../DefaultCompletedCheckpointStore.java | 6 +-
.../EmbeddedCompletedCheckpointStore.java | 20 +++-
.../PerJobCheckpointRecoveryFactory.java | 41 ++++++--
.../StandaloneCheckpointRecoveryFactory.java | 12 ++-
.../StandaloneCompletedCheckpointStore.java | 36 ++++++-
.../ZooKeeperCheckpointRecoveryFactory.java | 9 +-
.../executiongraph/DefaultExecutionGraph.java | 2 -
.../EmbeddedHaServicesWithLeadershipControl.java | 17 ++-
.../flink/runtime/scheduler/SchedulerBase.java | 1 +
.../flink/runtime/scheduler/SchedulerUtils.java | 18 +++-
.../scheduler/adaptive/AdaptiveScheduler.java | 1 +
.../flink/runtime/state/SharedStateRegistry.java | 10 +-
.../runtime/state/SharedStateRegistryFactory.java | 7 +-
.../apache/flink/runtime/util/ZooKeeperUtils.java | 13 ++-
.../CheckpointCoordinatorFailureTest.java | 9 +-
.../CheckpointCoordinatorMasterHooksTest.java | 2 -
.../CheckpointCoordinatorRestoringTest.java | 12 ++-
.../checkpoint/CheckpointCoordinatorTest.java | 29 +++--
.../CheckpointCoordinatorTestingUtils.java | 12 ---
.../DefaultCompletedCheckpointStoreTest.java | 3 +
.../FailoverStrategyCheckpointCoordinatorTest.java | 2 -
.../checkpoint/PerJobCheckpointRecoveryTest.java | 33 +++++-
.../TestingCheckpointRecoveryFactory.java | 9 +-
.../TestingCompletedCheckpointStore.java | 6 ++
.../ZooKeeperCompletedCheckpointStoreITCase.java | 3 +
.../ZooKeeperCompletedCheckpointStoreTest.java | 2 +
.../dispatcher/DispatcherFailoverITCase.java | 17 ++-
.../runtime/scheduler/SchedulerUtilsTest.java | 117 +++++++++++++++++++++
35 files changed, 442 insertions(+), 124 deletions(-)
copy flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/{StandaloneCheckpointRecoveryFactory.java => AbstractCompleteCheckpointStore.java} (52%)