This is an automated email from the ASF dual-hosted git repository.
zakelly pushed a change to branch release-2.0
in repository https://gitbox.apache.org/repos/asf/flink.git
from 458529f6aa8 [FLINK-37437][state/forst] Fix #exist and #getFileStatus
to give the information of writing files (#26272)
new f2b5e28b04f [FLINK-37437][state/forst] Support file override in
wrapped file system
new 19b7a8649ee [FLINK-37437][state/forst] Unguarded file system to enable
stream sharing between threads.
new 891292fd449 [FLINK-37437][state/forst] Avoid the deletion of primary
directory in ForSt
new ed6eff64517 [FLINK-37437][state/forst] Store misc files in local for
rescaling
new 62694fae763 [FLINK-37437][state/forst] Bundle file cache entry with
mapping entry and release properly
new 9baec0bc14c [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(-)
