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

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.10.0
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Alex
• Reporter: Alex
• Created: 20/Sep/19 12:23
• Updated: 24/Oct/19 08:57
• Resolved: 24/Oct/19 08:57

Description

With FLINK-12481, 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.

Issue Links

• links to: GitHub Pull Request #9735