Zakelly commented on PR #24832: URL: https://github.com/apache/flink/pull/24832#issuecomment-2134878724
@jectpro7 Let me elaborate this a little more. This runner aims for encapsulating multiple callbacks into one mail, but still it runs the callback ASAP. There will be no waiting or gathering, and small batches are totally acceptable. We already have buffered the state requests in `AEC`, and I don't want to introduce more latency here. This is only a small optimization to reduce the mail and interaction with the queue of mail. So the rules are: 1. If there is any callback, there will be a mail. 2. There is at most one mail at the same time. 3. At each mail, the task thread will handle _**at most**_ specific number of callbacks. Hope this helps you know what I'm trying to do. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
