You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by za...@apache.org on 2024/05/07 09:26:29 UTC

(flink) branch master updated (ca441b847e8 -> afe4c79efa1)

This is an automated email from the ASF dual-hosted git repository.

zakelly pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from ca441b847e8 [FLINK-32852][JUnit5 Migration] Migrate the scheduler package of flink-runtime module to JUnit5 (#24732)
     add afe4c79efa1 [FLINK-32080][FLIP-306][checkpoint] Restoration of FileMergingSnapshotManager

No new revisions were added by this update.

Summary of changes:
 .../api/runtime/SavepointTaskStateManager.java     |   7 ++
 .../filemerging/FileMergingSnapshotManager.java    |  35 +++++-
 .../FileMergingSnapshotManagerBase.java            |  73 +++++++++++
 .../checkpoint/filemerging/PhysicalFile.java       |   4 +
 .../SubtaskFileMergingManagerRestoreOperation.java | 116 ++++++++++++++++++
 .../state/IncrementalRemoteKeyedStateHandle.java   |   2 +-
 .../flink/runtime/state/TaskStateManager.java      |  10 ++
 .../flink/runtime/state/TaskStateManagerImpl.java  |  11 ++
 .../FileMergingSnapshotManagerTestBase.java        | 136 ++++++++++++++++++++-
 .../runtime/state/OperatorStateBackendTest.java    |   2 +-
 .../runtime/state/SharedStateRegistryTest.java     |   2 +-
 .../state/TaskExecutorFileMergingManagerTest.java  |   4 +-
 .../flink/runtime/state/TestTaskStateManager.java  |  15 +++
 .../FsMergingCheckpointStorageLocationTest.java    |   2 +-
 .../operators/StreamTaskStateInitializerImpl.java  |  31 ++++-
 15 files changed, 435 insertions(+), 15 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/SubtaskFileMergingManagerRestoreOperation.java