This is an automated email from the ASF dual-hosted git repository.
srichter pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 201571b486f [FLINK-27992] Set ALWAYS chaining strategy for CepOperator
in ExecMatch
new f1e355437eb [FLINK-34134] Minor cleanup of unused parameters in
RocksDB backend.
new 22241080a80 [FLINK-34134] Introduce size/location statistics reporting
to StateObject interface.
new 210ab633350 [FLINK-34134] Add methods to determine local directory
sizes to FileUtils.
new 8e0e2ca97c9 [FLINK-34134] Implement handle-specific size/location
reporting methods.
new 9dc0f6f658b [FLINK-34134] Collect and report size/location statistics
during task restore.
new bdf31327775 [FLINK-34134] Add documentation.
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:
docs/content.zh/docs/ops/traces.md | 12 +++-
docs/content/docs/ops/traces.md | 12 +++-
.../main/java/org/apache/flink/util/FileUtils.java | 24 +++++++
.../java/org/apache/flink/util/FileUtilsTest.java | 13 ++++
.../KubernetesStateHandleStore.java | 5 ++
.../flink/runtime/checkpoint/OperatorState.java | 18 ++---
.../runtime/checkpoint/OperatorSubtaskState.java | 60 ++++++++--------
.../runtime/checkpoint/StateObjectCollection.java | 35 ++++-----
.../apache/flink/runtime/checkpoint/TaskState.java | 18 ++---
.../runtime/checkpoint/TaskStateSnapshot.java | 17 +++--
.../apache/flink/runtime/metrics/MetricNames.java | 1 +
.../runtime/state/AbstractChannelStateHandle.java | 19 +++--
.../flink/runtime/state/ChainedStateHandle.java | 23 +++---
.../flink/runtime/state/DirectoryStateHandle.java | 25 +++++--
.../state/IncrementalLocalKeyedStateHandle.java | 6 ++
.../state/IncrementalRemoteKeyedStateHandle.java | 25 ++++---
.../flink/runtime/state/KeyGroupsStateHandle.java | 11 +++
.../runtime/state/OperatorStreamStateHandle.java | 5 ++
.../state/RetrievableStreamStateHandle.java | 5 ++
.../flink/runtime/state/SnapshotDirectory.java | 4 +-
.../apache/flink/runtime/state/StateObject.java | 57 +++++++++++++++
.../changelog/ChangelogStateBackendHandle.java | 5 ++
.../inmemory/InMemoryChangelogStateHandle.java | 5 ++
.../runtime/state/filesystem/FileStateHandle.java | 14 ++++
.../state/memory/ByteStreamStateHandle.java | 5 ++
.../IncrementalLocalKeyedStateHandleTest.java | 84 ++++++++++++++++++++++
.../IncrementalRemoteKeyedStateHandleTest.java | 19 +++++
.../runtime/state/KeyGroupsStateHandleTest.java | 21 ++++++
.../state/filesystem/FileStateHandleTest.java | 37 ++++++++++
.../state/memory/ByteStreamStateHandleTest.java | 19 +++++
.../state/RocksDBKeyedStateBackendBuilder.java | 5 --
.../streaming/state/StateHandleDownloadSpec.java | 2 +-
.../snapshot/RocksIncrementalSnapshotStrategy.java | 9 ++-
.../RocksIncrementalSnapshotStrategyTest.java | 11 ++-
.../api/operators/BackendRestorerProcedure.java | 9 ++-
.../operators/StreamTaskStateInitializerImpl.java | 62 +++++++++++++---
.../operators/BackendRestorerProcedureTest.java | 11 ++-
.../StreamTaskStateInitializerImplTest.java | 63 ++++++++++++++--
38 files changed, 627 insertions(+), 149 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/state/IncrementalLocalKeyedStateHandleTest.java
