You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Alex (Jira)" <ji...@apache.org> on 2019/09/20 12:25:00 UTC
[jira] [Updated] (FLINK-14156) Execute/run processing timer
triggers taking into account operator level mailbox loops
[ https://issues.apache.org/jira/browse/FLINK-14156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alex updated FLINK-14156:
-------------------------
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.
was:
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.
> 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
> Priority: Major
>
> 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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)