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 a0f07fef4e5 [FLINK-36402] edgeRemapings typo fixed to edgeRemappings
new 67b02e48941 [FLINK-37437][state/forst] Support file override in
wrapped file system
new 7b1e3581633 [FLINK-37437][state/forst] Unguarded file system to enable
stream sharing between threads.
new d3015df4189 [FLINK-37437][state/forst] Avoid the deletion of primary
directory in ForSt
new 3e399312ddc [FLINK-37437][state/forst] Store misc files in local for
rescaling
new 972e205f8f6 [FLINK-37437][state/forst] Bundle file cache entry with
mapping entry and release properly
new c7aa1748cfe [FLINK-37437][state/forst] Bump forstjni version to 0.1.8
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
flink-dist/src/main/resources/META-INF/NOTICE | 2 +-
.../flink-statebackend-forst/pom.xml | 2 +-
.../state/forst/ForStKeyedStateBackendBuilder.java | 3 +
.../flink/state/forst/ForStResourceContainer.java | 6 ++
.../flink/state/forst/fs/ForStFlinkFileSystem.java | 35 ++++---
.../forst/fs/filemapping/FileMappingManager.java | 111 +++++++++++++-------
.../state/forst/fs/filemapping/MappingEntry.java | 19 ++++
.../state/forst/ForStResourceContainerTest.java | 3 +
.../state/forst/fs/FileMappingManagerTest.java | 34 +++---
.../state/forst/fs/ForStFlinkFileSystemTest.java | 116 +++++++++++++++++++++
10 files changed, 262 insertions(+), 69 deletions(-)
