You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2022/02/07 18:43:00 UTC
[flink] branch master updated (27cd145 -> 1fc87b6)
This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 27cd145 [FLINK-25952] Savepoints on S3 are not relocatable even if entropy injection is not enabled
add 35e4363 [FLINK-25955][runtime] Moves maximum retained checkpoints parameter extraction into utility method
add cfd85b5 [FLINK-25955][runtime] Makes TestingCheckpointIDCounter and TestingCompletedCheckpointStore more generic
add 1fc87b6 [FLINK-25955][runtime] Introduces CheckpointResourcesCleanupRunner
No new revisions were added by this update.
Summary of changes:
.../ApplicationDispatcherBootstrapITCase.java | 4 +-
.../DefaultCompletedCheckpointStoreUtils.java | 31 ++
.../clusterframework/ApplicationStatus.java | 54 +-
.../flink/runtime/dispatcher/Dispatcher.java | 92 +++-
.../runtime/dispatcher/DispatcherServices.java | 14 +-
.../runtime/dispatcher/JobDispatcherFactory.java | 4 +-
.../dispatcher/SessionDispatcherFactory.java | 4 +-
.../cleanup/CheckpointResourcesCleanupRunner.java | 230 ++++++++
.../CheckpointResourcesCleanupRunnerFactory.java | 51 ++
...ourceCleaner.java => CleanupRunnerFactory.java} | 27 +-
.../flink/runtime/scheduler/SchedulerUtils.java | 21 +-
.../DefaultCompletedCheckpointStoreUtilsTest.java | 17 +
.../DefaultSchedulerCheckpointCoordinatorTest.java | 32 +-
.../checkpoint/PerJobCheckpointRecoveryTest.java | 4 +-
.../checkpoint/TestingCheckpointIDCounter.java | 89 +++-
.../TestingCompletedCheckpointStore.java | 163 +++++-
.../clusterframework/ApplicationStatusTest.java | 65 +++
.../runtime/dispatcher/AbstractDispatcherTest.java | 2 +
.../dispatcher/DispatcherFailoverITCase.java | 26 +-
.../dispatcher/DispatcherResourceCleanupTest.java | 6 +-
.../flink/runtime/dispatcher/DispatcherTest.java | 54 +-
.../runtime/dispatcher/MiniDispatcherTest.java | 33 +-
.../runtime/dispatcher/TestingDispatcher.java | 13 +-
.../dispatcher/TestingJobManagerRunnerFactory.java | 39 +-
...ngJobMasterServiceLeadershipRunnerFactory.java} | 27 +-
.../CheckpointResourcesCleanupRunnerTest.java | 589 +++++++++++++++++++++
.../cleanup/TestingCleanupRunnerFactory.java | 52 ++
.../runner/DefaultDispatcherRunnerITCase.java | 21 +-
.../scheduler/adaptive/AdaptiveSchedulerTest.java | 7 +-
29 files changed, 1571 insertions(+), 200 deletions(-)
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/CheckpointResourcesCleanupRunner.java
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/CheckpointResourcesCleanupRunnerFactory.java
copy flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/{ResourceCleaner.java => CleanupRunnerFactory.java} (57%)
copy flink-runtime/src/{main/java/org/apache/flink/runtime/dispatcher/JobManagerRunnerFactory.java => test/java/org/apache/flink/runtime/dispatcher/TestingJobMasterServiceLeadershipRunnerFactory.java} (67%)
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/cleanup/CheckpointResourcesCleanupRunnerTest.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/cleanup/TestingCleanupRunnerFactory.java