Piotr Nowojski created FLINK-35528:
--------------------------------------
Summary: Skip execution of interruptible mails when yielding
Key: FLINK-35528
URL: https://issues.apache.org/jira/browse/FLINK-35528
Project: Flink
Issue Type: Sub-task
Components: Runtime / Checkpointing, Runtime / Task
Affects Versions: 1.20.0
Reporter: Piotr Nowojski
Assignee: Piotr Nowojski
When operators are yielding, for example waiting for async state access to
complete before a checkpoint, it would be beneficial to not execute
interruptible mails. Otherwise continuation mail for firing timers would be
continuously re-enqeueed. To achieve that MailboxExecutor must be aware which
mails are interruptible.
The easiest way to achieve this is to set MIN_PRIORITY for interruptible mails.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)