[jira] [Closed] (FLINK-17058) Adding TimeoutTrigger support nested triggers

["Aljoscha Krettek (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-17058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Aljoscha Krettek closed FLINK-17058.
------------------------------------
    Fix Version/s: 1.12.0
       Resolution: Fixed

master: 03b6d715801c9ae4e515932be154c01174cc3450

> Adding TimeoutTrigger support nested triggers
> ---------------------------------------------
>
>                 Key: FLINK-17058
>                 URL: https://issues.apache.org/jira/browse/FLINK-17058
>             Project: Flink
>          Issue Type: Improvement
>          Components: API / DataStream
>            Reporter: Roey Shem Tov
>            Assignee: Roey Shem Tov
>            Priority: Minor
>              Labels: pull-request-available
>             Fix For: 1.12.0
>
>         Attachments: ProcessingTimeoutTrigger.java, ProcessingTimeoutTrigger.java
>
>
> Hello,
> first Jira ticket that im opening here so if there is any mistakes of how doing it, please recorrect me.
> My suggestion is to add a TimeoutTrigger that apply as nestedTrigger(as example how the PurgeTrigger does).
> The TimeoutTrigger will support ProcessTime/EventTime and will have 2 timeous:
>  # Const timeout - when the first element of the window is arriving it is opening a timeout of X millis - after that the window will be evaluate.
>  # Continual timeout - each record arriving will increase the timeout of the evaluation of the window.
>  
> I found it very useful in our case when using flink, and i would like to work on it (if it is possible).
> what do you think?



--
This message was sent by Atlassian Jira
(v8.3.4#803005)