CrynetLogistics commented on pull request #17244: URL: https://github.com/apache/flink/pull/17244#issuecomment-918402400
@dannycranmer Thanks for your comment a little earlier about concurrency and thread interleaving. * I have added 2 additional tests to cover situations where a timer triggers a flush while another is in flight. To give us confidence in thread interleaving behaviour and to alert users allowing a non mailbox thread into the class. * I can also confirm that for the 4 `public` methods and other callback methods (`MailboxExecutor` and `ProcessingTimeService`), the only thread that may enter any of these is the mailbox thread. Maybe with the exception of `snapshotState()` which is read-only. -- 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]
