[jira] [Created] (FLINK-14156) Execute/run processing timer triggers taking into account operator level mailbox loops

[Shang Yuanchun (Jira)]

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)