ASF Git Repos - flink.git/commit

author	Hangxiang Yu <masteryhx@gmail.com>
	Thu, 28 Apr 2022 01:45:42 +0000 (09:45 +0800)
committer	Roman <khachatryan.roman@gmail.com>
	Thu, 12 May 2022 13:04:47 +0000 (15:04 +0200)
commit	7d2ca7b146180148fbc5dbc4e8de40a0651be22d
tree	d3a5607bd9a8935e5a486851ec3883a33f8e1595	tree \| snapshot
parent	94e8f54766be527d511c73cb446546e83f5b0037	commit \| diff

[FLINK-25470][changelog] Expose more metrics of ChangelogStateBackend and materialization

22 files changed:

docs/content.zh/docs/ops/metrics.md		diff \| blob \| history
docs/content/docs/ops/metrics.md		diff \| blob \| history
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogStorageMetricGroup.java		diff \| blob \| history
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/ThreadSafeSimpleCounter.java	[new file with mode: 0644]	blob
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestUtils.java	[new file with mode: 0644]	blob
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]	diff \| blob \| history
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractChangelogStateBackend.java		diff \| blob \| history
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java		diff \| blob \| history
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogMaterializationMetricGroup.java	[new file with mode: 0644]	blob
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogStateBackend.java		diff \| blob \| history
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogStateBackendMetricGroup.java	[new file with mode: 0644]	blob
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/DeactivatedChangelogStateBackend.java		diff \| blob \| history
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java		diff \| blob \| history
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackendTest.java		diff \| blob \| history
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogMetricGroupTest.java	[new file with mode: 0644]	blob
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateBackendTestUtils.java		diff \| blob \| history
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateDiscardTest.java		diff \| blob \| history
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/OperatorSnapshotFuturesTest.java		diff \| blob \| history
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnableTest.java		diff \| blob \| history
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java		diff \| blob \| history
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationITCase.java		diff \| blob \| history
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationTestBase.java		diff \| blob \| history

Apache Flink

RSS Atom