[FLINK-25470][changelog] Expose more metrics of ChangelogStateBackend and materialization
authorHangxiang Yu <masteryhx@gmail.com>
Thu, 28 Apr 2022 01:45:42 +0000 (09:45 +0800)
committerRoman <khachatryan.roman@gmail.com>
Thu, 12 May 2022 13:04:47 +0000 (15:04 +0200)
commit7d2ca7b146180148fbc5dbc4e8de40a0651be22d
treed3a5607bd9a8935e5a486851ec3883a33f8e1595
parent94e8f54766be527d511c73cb446546e83f5b0037
[FLINK-25470][changelog] Expose more metrics of ChangelogStateBackend and materialization
22 files changed:
docs/content.zh/docs/ops/metrics.md
docs/content/docs/ops/metrics.md
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogStorageMetricGroup.java
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/ThreadSafeSimpleCounter.java [new file with mode: 0644]
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestUtils.java [new file with mode: 0644]
flink-runtime/src/test/java/org/apache/flink/runtime/testutils/ExceptionallyDoneFuture.java [moved from flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/ExceptionallyDoneFuture.java with 97% similarity]
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractChangelogStateBackend.java
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogMaterializationMetricGroup.java [new file with mode: 0644]
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogStateBackend.java
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogStateBackendMetricGroup.java [new file with mode: 0644]
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/DeactivatedChangelogStateBackend.java
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackendTest.java
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogMetricGroupTest.java [new file with mode: 0644]
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateBackendTestUtils.java
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateDiscardTest.java
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/OperatorSnapshotFuturesTest.java
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnableTest.java
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationITCase.java
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationTestBase.java