This is an automated email from the ASF dual-hosted git repository.
roman pushed a change to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git
from d4c52b372a8 [hotfix][doc] Fix typo in JobManagerOptions (#22992)
new c6c54412bf7 [FLINK-29913][checkpointing] Use PhysicalStateHandleID as
a key for shared state of IncrementalRemoteKeyedStateHandle
new d00e2eb73aa [refactor][test] Introduce DiscardRecordedStateObject to
avoid using mocks for state handles
new bf8456df695 [FLINK-29913][checkpointing] Remove de-duplication from
SharedStateRegistry#registerReference()
new aad658910fd [hotfix][state-changelog] Don't trigger new
materialization unless the previous one is confirmed/failed/cancelled
The 4 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:
.../metadata/MetadataV2V3SerializerBase.java | 31 ++--
.../runtime/state/IncrementalKeyedStateHandle.java | 69 ++++++++-
.../state/IncrementalLocalKeyedStateHandle.java | 16 +-
.../state/IncrementalRemoteKeyedStateHandle.java | 86 +++++------
.../state/PlaceholderStreamStateHandle.java | 7 +-
.../runtime/state/SharedStateRegistryImpl.java | 114 +++++++--------
.../changelog/ChangelogStateBackendHandle.java | 31 ++--
.../checkpoint/CheckpointCoordinatorTest.java | 116 ++++++++-------
.../checkpoint/metadata/CheckpointTestUtils.java | 27 ++--
.../runtime/scheduler/SchedulerUtilsTest.java | 34 +++--
.../runtime/state/DiscardRecordedStateObject.java | 30 ++--
.../IncrementalRemoteKeyedStateHandleTest.java | 161 +++++++++++++--------
.../runtime/state/SharedStateRegistryTest.java | 48 ++----
...le.java => TestingRelativeFileStateHandle.java} | 22 ++-
.../runtime/state/TestingStreamStateHandle.java | 8 +-
.../changelog/ChangelogKeyedStateBackend.java | 28 ++++
.../changelog/ChangelogKeyedStateBackendTest.java | 56 +++++++
.../common/PeriodicMaterializationManager.java | 33 ++++-
.../state/RocksDBKeyedStateBackendBuilder.java | 8 +-
.../streaming/state/RocksDBStateDownloader.java | 24 +--
.../streaming/state/RocksDBStateUploader.java | 64 ++++----
.../RocksDBIncrementalRestoreOperation.java | 4 +-
.../state/restore/RocksDBRestoreResult.java | 11 +-
.../snapshot/RocksDBSnapshotStrategyBase.java | 38 +++--
.../snapshot/RocksIncrementalSnapshotStrategy.java | 120 ++++++++-------
.../snapshot/RocksNativeFullSnapshotStrategy.java | 44 +++---
.../state/snapshot/RocksSnapshotUtil.java | 13 --
.../state/EmbeddedRocksDBStateBackendTest.java | 24 +--
.../state/RocksDBStateDownloaderTest.java | 19 ++-
.../streaming/state/RocksDBStateUploaderTest.java | 36 +++--
.../RocksIncrementalSnapshotStrategyTest.java | 22 +--
.../test/checkpointing/StateHandleReuseITCase.java | 6 +-
32 files changed, 775 insertions(+), 575 deletions(-)
copy
flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/tuple/base/TupleComparatorTestBase.java
=>
flink-runtime/src/test/java/org/apache/flink/runtime/state/DiscardRecordedStateObject.java
(53%)
copy
flink-runtime/src/test/java/org/apache/flink/runtime/state/{TestingStreamStateHandle.java
=> TestingRelativeFileStateHandle.java} (66%)
