[
https://issues.apache.org/jira/browse/FLINK-37383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931786#comment-17931786
]
Rafael Zimmermann commented on FLINK-37383:
-------------------------------------------
I've addressed all comments in the PR and am waiting for the review. With this
fix applied, we now have perfect control over the throttle of our Flink
pipeline.
> ThrottleIterator from examples/utils does not properly throttle on next
> window after throttle is applied
> --------------------------------------------------------------------------------------------------------
>
> Key: FLINK-37383
> URL: https://issues.apache.org/jira/browse/FLINK-37383
> Project: Flink
> Issue Type: Bug
> Components: Examples
> Affects Versions: 1.20.1
> Reporter: Rafael Zimmermann
> Priority: Minor
> Labels: pull-request-available
>
> The throttle function available on
> `flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/utils/ThrottledIterator.java`
> is updating its last batch check time before the sleep operation, causing it
> to underestimate the elapsed time and allow approximately double the intended
> throughput rate.
> [##26203] contains a fix for it
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
