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 d14c2d58943 [FLINK-37658][docs] Improve the Datagen connector docs
add 932fd5930d8 [FLINK-34558][state] Support tracking state size (#25837)
No new revisions were added by this update.
Summary of changes:
docs/content.zh/docs/ops/metrics.md | 167 +++++++
docs/content/docs/ops/metrics.md | 167 +++++++
...on.html => state_size_track_configuration.html} | 16 +-
...ction.html => state_size_tracking_section.html} | 16 +-
.../flink/annotation/docs/Documentation.java | 1 +
.../flink/configuration/StateSizeTrackOptions.java | 62 +++
.../state/api/input/MultiStateKeyIteratorTest.java | 4 +
.../network/KvStateRequestSerializerTest.java | 2 +
.../runtime/state/AbstractKeyedStateBackend.java | 22 +-
.../state/AbstractKeyedStateBackendBuilder.java | 4 +
.../flink/runtime/state/AbstractStateBackend.java | 4 +
.../runtime/state/hashmap/HashMapStateBackend.java | 5 +
.../runtime/state/heap/HeapKeyedStateBackend.java | 3 +
.../state/heap/HeapKeyedStateBackendBuilder.java | 4 +
...ckState.java => AbstractMetricsTrackState.java} | 116 ++++-
.../state/metrics/LatencyTrackingListState.java | 188 -------
.../state/metrics/LatencyTrackingMapState.java | 377 --------------
.../state/metrics/LatencyTrackingStateConfig.java | 80 +--
.../state/metrics/LatencyTrackingValueState.java | 111 -----
...e.java => MetricsTrackingAggregatingState.java} | 70 ++-
.../state/metrics/MetricsTrackingListState.java | 273 +++++++++++
.../state/metrics/MetricsTrackingMapState.java | 542 +++++++++++++++++++++
...tate.java => MetricsTrackingReducingState.java} | 71 ++-
...Config.java => MetricsTrackingStateConfig.java} | 72 +--
...ctory.java => MetricsTrackingStateFactory.java} | 63 ++-
.../state/metrics/MetricsTrackingValueState.java | 140 ++++++
.../state/metrics/SizeTrackingStateConfig.java | 73 +++
...LatencyMetricBase.java => StateMetricBase.java} | 14 +-
.../flink/runtime/state/StateBackendTestBase.java | 46 ++
.../flink/runtime/state/StateBackendTestUtils.java | 1 +
.../state/StateSnapshotCompressionTest.java | 2 +
.../metrics/LatencyTrackingStateFactoryTest.java | 175 -------
...va => MetricsTrackingAggregatingStateTest.java} | 50 +-
...Test.java => MetricsTrackingListStateTest.java} | 55 ++-
...eTest.java => MetricsTrackingMapStateTest.java} | 159 +++++-
....java => MetricsTrackingReducingStateTest.java} | 46 +-
...st.java => MetricsTrackingStateConfigTest.java} | 58 ++-
.../metrics/MetricsTrackingStateFactoryTest.java | 256 ++++++++++
...Base.java => MetricsTrackingStateTestBase.java} | 20 +-
...est.java => MetricsTrackingValueStateTest.java} | 44 +-
.../state/ttl/mock/MockKeyedStateBackend.java | 3 +
.../ttl/mock/MockKeyedStateBackendBuilder.java | 4 +
.../runtime/state/ttl/mock/MockStateBackend.java | 2 +
.../v2/AsyncKeyedStateBackendAdaptorTest.java | 2 +
.../streaming/runtime/tasks/TestStateBackend.java | 4 +
.../changelog/ChangelogKeyedStateBackend.java | 8 +-
.../changelog/ChangelogKeyedStateBackendTest.java | 2 +
.../state/changelog/ChangelogStateDiscardTest.java | 2 +
.../flink/state/forst/ForStStateBackend.java | 5 +
.../forst/sync/ForStSyncKeyedStateBackend.java | 3 +
.../sync/ForStSyncKeyedStateBackendBuilder.java | 6 +
.../state/rocksdb/EmbeddedRocksDBStateBackend.java | 7 +-
.../state/rocksdb/RocksDBKeyedStateBackend.java | 3 +
.../rocksdb/RocksDBKeyedStateBackendBuilder.java | 6 +
.../flink/state/rocksdb/RocksDBTestUtils.java | 3 +
.../benchmark/StateBackendBenchmarkUtils.java | 3 +
.../flink/test/state/BackendSwitchSpecs.java | 3 +
57 files changed, 2518 insertions(+), 1127 deletions(-)
copy docs/layouts/shortcodes/generated/{state_latency_tracking_section.html =>
state_size_track_configuration.html} (53%)
copy docs/layouts/shortcodes/generated/{state_latency_tracking_section.html =>
state_size_tracking_section.html} (53%)
create mode 100644
flink-core/src/main/java/org/apache/flink/configuration/StateSizeTrackOptions.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/{AbstractLatencyTrackState.java
=> AbstractMetricsTrackState.java} (54%)
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/LatencyTrackingListState.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/LatencyTrackingMapState.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/LatencyTrackingValueState.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/{LatencyTrackingAggregatingState.java
=> MetricsTrackingAggregatingState.java} (57%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/MetricsTrackingListState.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/MetricsTrackingMapState.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/{LatencyTrackingReducingState.java
=> MetricsTrackingReducingState.java} (57%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/{LatencyTrackingStateConfig.java
=> MetricsTrackingStateConfig.java} (51%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/{LatencyTrackingStateFactory.java
=> MetricsTrackingStateFactory.java} (71%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/MetricsTrackingValueState.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/SizeTrackingStateConfig.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/{StateLatencyMetricBase.java
=> StateMetricBase.java} (90%)
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/state/metrics/LatencyTrackingStateFactoryTest.java
rename
flink-runtime/src/test/java/org/apache/flink/runtime/state/metrics/{LatencyTrackingAggregatingStateTest.java
=> MetricsTrackingAggregatingStateTest.java} (66%)
rename
flink-runtime/src/test/java/org/apache/flink/runtime/state/metrics/{LatencyTrackingListStateTest.java
=> MetricsTrackingListStateTest.java} (60%)
rename
flink-runtime/src/test/java/org/apache/flink/runtime/state/metrics/{LatencyTrackingMapStateTest.java
=> MetricsTrackingMapStateTest.java} (53%)
rename
flink-runtime/src/test/java/org/apache/flink/runtime/state/metrics/{LatencyTrackingReducingStateTest.java
=> MetricsTrackingReducingStateTest.java} (62%)
rename
flink-runtime/src/test/java/org/apache/flink/runtime/state/metrics/{LatencyTrackingStateConfigTest.java
=> MetricsTrackingStateConfigTest.java} (59%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/state/metrics/MetricsTrackingStateFactoryTest.java
rename
flink-runtime/src/test/java/org/apache/flink/runtime/state/metrics/{LatencyTrackingStateTestBase.java
=> MetricsTrackingStateTestBase.java} (87%)
rename
flink-runtime/src/test/java/org/apache/flink/runtime/state/metrics/{LatencyTrackingValueStateTest.java
=> MetricsTrackingValueStateTest.java} (60%)
