: Yuan,Youjun
抄送: Timo Walther ; user@flink.apache.org
主题: Re: 答复: 答复: TumblingProcessingTimeWindow emits extra results for a same
window
Hi Youjun,
The rowtime value in udf:EXTRACT(EPOCH FROM rowtime) is different from the
rowtime value of window. Sql will be parsed and translated into some nodes
r01"
> ,"min_ts":1531447919981,"max_ts":1531448159975}
>
> {"timestamp":153144816,"cnt":3278178,"userId":"user01"
> ,"min_ts":1531448159098,"max_ts":1531448399977}
>
> {"timestamp":15
;:"user01","min_ts":1531447919981,"max_ts":1531448159975}
{"timestamp":153144816,"cnt":3278178,"userId":"user01","min_ts":1531448159098,"max_ts":1531448399977}
{"timestamp":153144816,"cnt"
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 vibrated.
Otherwise, there are some bugs we don't know.
Best, Hequn
On Thu, Jul 12, 2018 at 8:00 PM, Yuan,Yo
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 stably
reproduce the issue on my local machine.
The user ids are actually the same, I have doubled checked that.
Now, I am wondering coul
