Hi Marco Villalobos-2 unfortunately I don't think Tumbling window will work in my case.
The reasons: 1. Window must start only when there is a new event, and previous window is closed. The new Tumbling window is created just after previews one is purged. In my case I have to use SessionWindow where Session windows do not overlap and do not have a fixed start and end time, in contrast to tumbling windows and sliding windows [1]. 2. My logic required to close the window earlier, before Window maxTime hence custom trigger. The issue I'm having though is that My Trigger firres the windwo two times. First time from onElement method and secodn time from onProcessignTime method. [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/windows.html#session-windows -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
