akalash commented on a change in pull request #16556:
URL: https://github.com/apache/flink/pull/16556#discussion_r678126200
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
##########
@@ -665,6 +674,19 @@ private void executeInvoke() throws Exception {
afterInvoke();
}
+ private void throughputCalculationSetup() {
+ systemTimerService.registerTimer(
+ systemTimerService.getCurrentProcessingTime()
Review comment:
I thought about that but if the delay happens it can lead to the
situation when `scheduleAtFixedRate` submit several throughput calculations
which don't make sense. It is better to submit the calculation only when the
last calculation was finished.
--
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]
