RE: Sliding Window - Weird behaviour

2017-04-13 Thread Radu Tudoran
-Original Message- From: madhairsilence [mailto:harish.kum...@tcs.com] Sent: Thursday, April 13, 2017 12:25 PM To: dev@flink.apache.org Subject: Re: Sliding Window - Weird behaviour Hi Xingcan Thanks for the answer. But up to my understanding countWindow(4,2) - Should wait for 4 elements

Re: Sliding Window - Weird behaviour

2017-04-13 Thread madhairsilence
Hi Xingcan Thanks for the answer. But up to my understanding countWindow(4,2) - Should wait for 4 elements (or window not more than 4 element) and once the window is ready, slide two items Now if I have to stopped asking why questions and worry about my current problem, how do I achieve this exp

Re: Sliding Window - Weird behaviour

2017-04-13 Thread Xingcan Cui
​Hi harish, I will not argue for the correctness of the result​s, but just tell you why this happens. The countWindow(2, 1) can be regarded as two separate processes: 1) maintain a window whose size *not exceeds* 2 and 2) trigger window evaluation every single record. Actually, in Flink the two