This is an automated email from the ASF dual-hosted git repository.
leiyanfei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 4ae4b871c08 [FLINK-36957][Datastream] Implement asyc state version of
stream flatmap (#25848)
add c9311756582 [FLINK-36899][state/forst] Introduce metrics for forst
cache (#25884)
No new revisions were added by this update.
Summary of changes:
docs/content.zh/docs/ops/metrics.md | 35 ++++++++++++++++++++
docs/content/docs/ops/metrics.md | 35 ++++++++++++++++++++
.../flink/state/forst/ForStResourceContainer.java | 14 +++++---
.../flink/state/forst/ForStStateBackend.java | 7 +++-
.../flink/state/forst/fs/ForStFlinkFileSystem.java | 10 ++++--
.../forst/fs/cache/BundledCacheLimitPolicy.java | 12 +++++++
.../state/forst/fs/cache/CacheLimitPolicy.java | 19 ++++++++++-
.../flink/state/forst/fs/cache/FileBasedCache.java | 37 +++++++++++++++++++++-
.../forst/fs/cache/SizeBasedCacheLimitPolicy.java | 10 ++++++
.../forst/fs/cache/SpaceBasedCacheLimitPolicy.java | 13 ++++++++
.../apache/flink/state/forst/ForStExtension.java | 1 +
.../state/forst/ForStResourceContainerTest.java | 8 ++++-
.../state/forst/ForStStateBackendConfigTest.java | 8 +++--
.../state/forst/fs/ForStFlinkFileSystemTest.java | 36 +++++++++++++++++++--
14 files changed, 229 insertions(+), 16 deletions(-)
