[ https://issues.apache.org/jira/browse/FLINK-17058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097624#comment-17097624 ]
Roey Shem Tov commented on FLINK-17058: --------------------------------------- [~aljoscha] sorry for late response, took me a while to understand all the test mechanisem of flink, (by the way great test infrastructure). I opened pull request with the tests, altaugh i changed a little bit what we talked about: # onProcessingTime call the nestedTrigger,onProcessingTime but return TriggerResult.FIRE, that because understanding that when processingTimer emit it should FIRE the window. # onElement method check the TriggerResult of the nestedTrigger, if the nestedTrigger return any fire result, we are gonna clear the state (because timeout should be reset). # added new flag of shouldClearAtTimeout meaning if the timeout arrived should i clear the nestedTrigger, for example if i had ProccessingTimeoutTrigger.of(CountTrigger.of(4)) with timeout of 10 seconds, and after 10 seconds i had 3 records , so when i emit the window should i reset the count to zero?(the record`s counter), or keeping it on 3. Please provide me any information if something is missing. > 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 > 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)