[GitHub] [flink] rkhachatryan commented on a diff in pull request #19441: [FLINK-27187][state/changelog] Add changelog storage metric totalAttemptsPerUpload

2022-04-22 Thread GitBox
rkhachatryan commented on code in PR #19441: URL: https://github.com/apache/flink/pull/19441#discussion_r856152839 ## flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/ChangelogStorageMetricsTest.java: ## @@ -295,6 +346,55 @@ public void close() { }

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19441: [FLINK-27187][state/changelog] Add changelog storage metric totalAttemptsPerUpload

2022-04-21 Thread GitBox
rkhachatryan commented on code in PR #19441: URL: https://github.com/apache/flink/pull/19441#discussion_r854959208 ## flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/ChangelogStorageMetricsTest.java: ## @@ -295,6 +346,55 @@ public void close() { }

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19441: [FLINK-27187][state/changelog] Add changelog storage metric totalAttemptsPerUpload

2022-04-21 Thread GitBox
rkhachatryan commented on code in PR #19441: URL: https://github.com/apache/flink/pull/19441#discussion_r854959208 ## flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/ChangelogStorageMetricsTest.java: ## @@ -295,6 +346,55 @@ public void close() { }

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19441: [FLINK-27187][state/changelog] Add changelog storage metric totalAttemptsPerUpload

2022-04-21 Thread GitBox
rkhachatryan commented on code in PR #19441: URL: https://github.com/apache/flink/pull/19441#discussion_r854958316 ## flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/ChangelogStorageMetricsTest.java: ## @@ -295,6 +349,39 @@ public void close() { }

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19441: [FLINK-27187][state/changelog] Add changelog storage metric totalAttemptsPerUpload

2022-04-20 Thread GitBox
rkhachatryan commented on code in PR #19441: URL: https://github.com/apache/flink/pull/19441#discussion_r854012871 ## flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/ChangelogStorageMetricsTest.java: ## @@ -295,6 +349,39 @@ public void close() { }

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19441: [FLINK-27187][state/changelog] Add changelog storage metric totalAttemptsPerUpload

2022-04-20 Thread GitBox
rkhachatryan commented on code in PR #19441: URL: https://github.com/apache/flink/pull/19441#discussion_r853964273 ## flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/ChangelogStorageMetricsTest.java: ## @@ -295,6 +349,39 @@ public void close() { }

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19441: [FLINK-27187][state/changelog] Add changelog storage metric totalAttemptsPerUpload

2022-04-20 Thread GitBox
rkhachatryan commented on code in PR #19441: URL: https://github.com/apache/flink/pull/19441#discussion_r853867505 ## flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/ChangelogStorageMetricsTest.java: ## @@ -295,6 +349,39 @@ public void close() { }

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19441: [FLINK-27187][state/changelog] Add changelog storage metric totalAttemptsPerUpload

2022-04-19 Thread GitBox
rkhachatryan commented on code in PR #19441: URL: https://github.com/apache/flink/pull/19441#discussion_r852664044 ## flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/ChangelogStorageMetricsTest.java: ## @@ -295,6 +349,39 @@ public void close() { }