curcur opened a new pull request #16504: URL: https://github.com/apache/flink/pull/16504
## What is the purpose of the change This PR provides access to mailbox executor from KeyedStateBackend There are several places in ChangelogStateBackend that needs execute actions from task thread DFS writer: collect so far uploaded changes; handle upload results after completion ChangelogKeyedStateBackend: checkpointing to combine state handles upon upload completion by writer ChangelogKeyedStateBackend: materialization take snapshot (sync phase) and handle results of the async phase Provide access to mailbox executor can simply threading model without lock. ## Brief changelog - Move the interface `MailboxExecutor` to flink-core - Provide mailexecutor access through Environment - Allow StreamTask to assign mailboxexecutor after initializing it. -- 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]
