I think the problem is that you are sending only 50 events, but thats will not be the case in real world.
Here I think the last event is still in the window as its waiting for next event to check for expiration, without another event arriving it does not know the current running time of the system and hence it cannot expire. If we need to expire all events then we have to use the normal time batch window where events will be mapped to the server time and in that case replay of events will not work. Suho On Thu, Apr 28, 2016 at 4:47 PM, Gihan Anuruddha <gi...@wso2.com> wrote: > Hi All, > > We are using external time windows in second based and minute based to do > some aggregate operations as below. > > from tempDecompressedEventStream#window.externalTimeBatch(startTime, 1 > sec, 0) > > As we observed, this will not flush the current values after some time. > As an example, if I send 50 events to second based external time batch > stream only 49 events I'm getting. We want to flush that last remaining > event after some time in order to execute other analytics correctly. Is > there anyway to achieve this? > > Regards, > Gihan > > W.G. Gihan Anuruddha > Senior Software Engineer | WSO2, Inc. > M: +94772272595 > -- *S. Suhothayan* Technical Lead & Team Lead of WSO2 Complex Event Processor *WSO2 Inc. *http://wso2.com * <http://wso2.com/>* lean . enterprise . middleware *cell: (+94) 779 756 757 | blog: http://suhothayan.blogspot.com/ <http://suhothayan.blogspot.com/>twitter: http://twitter.com/suhothayan <http://twitter.com/suhothayan> | linked-in: http://lk.linkedin.com/in/suhothayan <http://lk.linkedin.com/in/suhothayan>*
_______________________________________________ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
