Hi Guys Is there any insight into this ? Thanks Mans On Monday, November 13, 2017 11:19 AM, M Singh <mans2si...@yahoo.com> wrote:
Hi Flink Users I have a few questions about triggers: If a trigger returns TriggerResult.FIRE from say the onProcessingTime method - the window computation is triggered but elements are kept in the window. If there a second invocation of the onProcessingTime method will the elements from the previous window (which were not purged) a part of the new window computation along with new events added since the last FIRE event ? Secondly, how does the FIRE option affect the sliding window computation ? If there are any other insights/pitfalls while dealing with this, please let me know. Thanks Mans