curcur opened a new pull request #16531: URL: https://github.com/apache/flink/pull/16531
## What is the purpose of the change This PR provides access to mailbox executor from KeyedStateBackend There are several places in ChangelogStateBackend that need execute actions from the 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 a snapshot (sync phase) and handle results of the async phase Provide access to mailbox executor can simply threading model without a lock. ## Brief changelog - Move the interface MailboxExecutor to flink-runtime - Provide mailexecutor access through Environment - Allow StreamTask to assign mailboxexecutor after initializing it. ## Verifying this change existing tests -- 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
