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 1b01b521153 [FLINK-38364][streaming-java] Implement async state
version of ProcessingTimeoutTrigger (#27027)
add 78f6e779137 [FLINK-38336][state/forst] Avoid data copy during failover
for ForSt statebackend (#27042)
No new revisions were added by this update.
Summary of changes:
.../flink/state/forst/ForStKeyedStateBackend.java | 14 +-
.../state/forst/ForStKeyedStateBackendBuilder.java | 15 +-
.../flink/state/forst/ForStPathContainer.java | 193 +++++++++++++++++++++
.../flink/state/forst/ForStResourceContainer.java | 114 +++++-------
.../flink/state/forst/ForStStateBackend.java | 52 +++---
.../datatransfer/DataTransferStrategyBuilder.java | 39 ++++-
.../forst/datatransfer/ForStStateDataTransfer.java | 10 +-
.../restore/ForStIncrementalRestoreOperation.java | 15 +-
.../forst/sync/ForStSyncKeyedStateBackend.java | 11 +-
.../sync/ForStSyncKeyedStateBackendBuilder.java | 4 +-
.../apache/flink/state/forst/ForStExtension.java | 10 +-
.../state/forst/ForStResourceContainerTest.java | 12 +-
.../state/forst/ForStStateBackendConfigTest.java | 27 ++-
.../flink/state/forst/ForStStateBackendTest.java | 6 +-
.../datatransfer/DataTransferStrategyTest.java | 78 ++++++++-
.../datatransfer/ForStStateDataTransferTest.java | 22 ++-
16 files changed, 460 insertions(+), 162 deletions(-)
create mode 100644
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStPathContainer.java
