Alex created FLINK-14156:
----------------------------
Summary: Execute/run processing timer triggers taking into account
operator level mailbox loops
Key: FLINK-14156
URL: https://issues.apache.org/jira/browse/FLINK-14156
Project: Flink
Issue Type: Sub-task
Reporter: Alex
With FLINK-12841, the timer triggers are executed by the mailbox thread and
passed to the mailbox with the maximum priority.
In case of operators that use {{mailbox.yield()}} (introduced in FLINK-13248),
current approach may execute timer triggers that belong to an upstream
operator. Such timer trigger, may potentially call
{{processElement|Watermark()}} which eventually would come back to the current
operator. This situation may be similar to FLINK-13063.
To avoid this, the proposal is to set mailbox letters priorities of timer
triggers with the priority of the operator that the trigger belongs to.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
