[GitHub] [flink] rkhachatryan commented on a diff in pull request #22772: [FLINK-19010][metric] Introduce subtask level restore metric

2023-07-18 Thread via GitHub
rkhachatryan commented on code in PR #22772: URL: https://github.com/apache/flink/pull/22772#discussion_r1266570337 ## flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskIOMetricGroup.java: ## @@ -128,6 +134,29 @@ public TaskIOMetricGroup(TaskMetricGroup

[GitHub] [flink] rkhachatryan commented on a diff in pull request #22772: [FLINK-19010][metric] Introduce subtask level restore metric

2023-07-12 Thread via GitHub
rkhachatryan commented on code in PR #22772: URL: https://github.com/apache/flink/pull/22772#discussion_r1261375807 ## flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskIOMetricGroup.java: ## @@ -67,10 +70,12 @@ public class TaskIOMetricGroup extends

[GitHub] [flink] rkhachatryan commented on a diff in pull request #22772: [FLINK-19010][metric] Introduce subtask level restore metric

2023-07-11 Thread via GitHub
rkhachatryan commented on code in PR #22772: URL: https://github.com/apache/flink/pull/22772#discussion_r1260137154 ## flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskIOMetricGroup.java: ## @@ -67,10 +70,12 @@ public class TaskIOMetricGroup extends

[GitHub] [flink] rkhachatryan commented on a diff in pull request #22772: [FLINK-19010][metric] Introduce subtask level restore metric

2023-06-20 Thread via GitHub
rkhachatryan commented on code in PR #22772: URL: https://github.com/apache/flink/pull/22772#discussion_r1234865147 ## flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskIOMetricGroup.java: ## @@ -67,10 +70,12 @@ public class TaskIOMetricGroup extends