Zakelly Lan created FLINK-37642:
-----------------------------------
Summary: Use the mailboxExecutor for operator in Async state
processing
Key: FLINK-37642
URL: https://issues.apache.org/jira/browse/FLINK-37642
Project: Flink
Issue Type: Improvement
Components: Runtime / Async State Processing
Reporter: Zakelly Lan
Currently, the operators of async state processing use the main mailbox
executor for callback execution, which has low priority. It's better to use the
one for `YieldingOperator`, as:
{code:java}
MailboxExecutor mailboxExecutor =
containingTask
.getMailboxExecutorFactory()
.createExecutor(configuration.getChainIndex());
{code}
It has higher priority, which could help us do efficient `yield()`.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
