Re: Apache Flink - How to destroy global window and release it's resources

Posted by Guowei Ma on Apr 11, 2019; 6:06am
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Apache-Flink-How-to-destroy-global-window-and-release-it-s-resources-tp27191p27197.html

Hi,

I think you could return a proper TriggerResult, which defines how to deal with the window elements after computing a window in your trigger implementation. You could find the detail information from the doc[1].

1. https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/stream/operators/windows.html#fire-and-purge

M Singh <[hidden email]> 于2019年4月11日周四 上午1:42写道：

Hi:

I have a use case where I need to create a global window where I need to wait for unknown time for certain events for a particular key.  I understand that I can create a global window and use a custom trigger to initiate the function computation.  But I am not sure how to destroy the window after the triggering conditions is satisfied and the the events are purged.

If there is any better way of dealing with this situation, please let me know.

Thanks

Mans