Re: TumblingProcessingTimeWindow emits extra results for a same window

2018-07-16 Thread Hequn Cheng
there are some bugs we don't know. > > Best, Hequn > > On Thu, Jul 12, 2018 at 8:00 PM, Yuan,Youjun wrote: > > Hi Timo, > > This problem happens 4-5 times a day on our online server, with ~15k > events per second load, and it is using PROCESSING time. So I don’t think I > can stab

Re: TumblingProcessingTimeWindow emits extra results for a same window

2018-07-16 Thread Aljoscha Krettek
extra results for a same >> window >> >> Hi Yuan, >> >> Haven't heard about this before. Which flink version do you use? The cause >> may be: >> 1. userId not 100% identical, for example contains invisible characters. >> 2. The machine clock vib

Re: TumblingProcessingTimeWindow emits extra results for a same window

2018-07-16 Thread Aljoscha Krettek
don't know. > > Best, Hequn > > On Thu, Jul 12, 2018 at 8:00 PM, Yuan,Youjun <mailto:yuanyou...@baidu.com>> wrote: > Hi Timo, > > This problem happens 4-5 times a day on our online server, with ~15k events > per second load, and it is using PROCESSING time. So I do

Re: TumblingProcessingTimeWindow emits extra results for a same window

2018-07-12 Thread Timo Walther
Hi Yuan, this sounds indeed weird. The SQL API uses regular DataStream API windows underneath so this problem should have come up earlier if this is problem in the implementation. Does this behavior reproducible on your local machine? One thing that comes to my mind is that the "userId"s mig