fredia commented on code in PR #22772:
URL: https://github.com/apache/flink/pull/22772#discussion_r1236211241
##########
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskIOMetricGroup.java:
##########
@@ -67,10 +70,12 @@ public class TaskIOMetricGroup extends
ProxyMetricGroup<TaskMetricGroup> {
private final Meter mailboxThroughput;
private final Histogram mailboxLatency;
private final SizeGauge mailboxSize;
+ private final Gauge<Long> initializingTime;
Review Comment:
Thanks for the suggestion, I originally wanted to keep its semantics
consistent with `initializingTime` at the job level, `initializingTime` will
return 0 when the task is not in initialization, and it will decrease to 0 the
moment when the task becomes running. I will change it to
`initializationDuration`, and let the duration stay after the task becomes
running.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
