fredia commented on code in PR #22787:
URL: https://github.com/apache/flink/pull/22787#discussion_r1245185849
##########
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##########
@@ -597,8 +597,7 @@ protected void processInput(MailboxDefaultAction.Controller
controller) throws E
resumeFuture = inputProcessor.getAvailableFuture();
} else if (changelogWriterAvailabilityProvider != null) {
// currently, waiting for changelog availability is reported as
busy
- // todo: add new metric (FLINK-24402)
- timer = null;
+ timer = new
GaugePeriodTimer(ioMetrics.getIoBackPressuredTimePerSecond());
Review Comment:
Thanks for the review and analysis, I moved the `changelogBusyTime` into the
busy time.
> So should the documentation be updated then?
Because we still treat `changelogBusyTime` as busy time, the documentation
can stay as it is.
--
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]
