This is an automated email from the ASF dual-hosted git repository.
roman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a390675 [FLINK-24986][tests] Replace anonymous StreamStateHandle class
add f9767a3 [hotfix][tests] Move assertions closer to test bodies
add d3b278e [FLINK-23486][state] Add changelog storage metrics
No new revisions were added by this update.
Summary of changes:
.../changelog/fs/BatchingStateChangeUploader.java | 20 +-
.../changelog/fs/ChangelogStorageMetricGroup.java | 143 +++++++++++
.../changelog/fs/FsStateChangelogStorage.java | 18 +-
.../fs/FsStateChangelogStorageFactory.java | 6 +-
.../flink/changelog/fs/RetryingExecutor.java | 39 ++-
.../flink/changelog/fs/StateChangeFsUploader.java | 25 +-
.../flink/changelog/fs/StateChangeUploader.java | 9 +-
.../fs/BatchingStateChangeUploaderTest.java | 25 +-
.../changelog/fs/ChangelogStorageMetricsTest.java | 282 +++++++++++++++++++++
.../changelog/fs/FsStateChangelogStorageTest.java | 7 +-
.../flink/changelog/fs/RetryingExecutorTest.java | 6 +-
.../UnregisteredChangelogStorageMetricGroup.java | 18 +-
.../metrics/groups/TaskManagerJobMetricGroup.java | 2 +-
.../TaskExecutorStateChangelogStoragesManager.java | 9 +-
.../changelog/StateChangelogStorageFactory.java | 4 +-
.../changelog/StateChangelogStorageLoader.java | 6 +-
.../InMemoryStateChangelogStorageFactory.java | 4 +-
.../flink/runtime/taskexecutor/TaskExecutor.java | 2 +-
.../runtime/metrics/CollectingMetricsReporter.java | 100 ++++++++
.../runtime/metrics/MetricRegistryImplTest.java | 87 +++----
.../metrics/groups/AbstractMetricGroupTest.java | 205 ++++++---------
.../metrics/groups/TaskMetricGroupTest.java | 5 +-
...kExecutorStateChangelogStoragesManagerTest.java | 38 ++-
.../inmemory/StateChangelogStorageLoaderTest.java | 16 +-
.../changelog/ChangelogStateBackendTestUtils.java | 9 +-
25 files changed, 842 insertions(+), 243 deletions(-)
create mode 100644
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogStorageMetricGroup.java
create mode 100644
flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/ChangelogStorageMetricsTest.java
copy
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcTestCheckpoint.java
=>
flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/UnregisteredChangelogStorageMetricGroup.java
(58%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/CollectingMetricsReporter.java
