Re: Re: Re: Re:Re: Window Aggregation and Window Join ability not work properly

2021-12-23 Thread Martijn Visser
> > *Sender:*Yun Gao > *Send Date:*Thu Dec 23 17:05:33 2021 > *Recipients:*cy > *CC:*'user@flink.apache.org' > *Subject:*Re: Re:Re: Window Aggregation and Window Join ability not work > properly > >> Hi Caiyi, >> >> I think if the

Re:Re: Re: Re:Re: Window Aggregation and Window Join ability not work properly

2021-12-23 Thread cy
inal Mail -- Sender:Yun Gao Send Date:Thu Dec 23 17:05:33 2021 Recipients:cy CC:'user@flink.apache.org' Subject:Re: Re:Re: Window Aggregation and Window Join ability not work properly Hi Caiyi, I think if the image shows all the records, after the change we should on

Re: Re: Re:Re: Window Aggregation and Window Join ability not work properly

2021-12-23 Thread Yun Gao
Sorry I mean 16:00:05, but it should be similar. --Original Mail -- Sender:Yun Gao Send Date:Thu Dec 23 17:05:33 2021 Recipients:cy CC:'user@flink.apache.org' Subject:Re: Re:Re: Window Aggregation and Window Join ability not work properly Hi Caiyi,

Re: Re:Re: Window Aggregation and Window Join ability not work properly

2021-12-23 Thread Yun Gao
Recipients:Yun Gao CC:'user@flink.apache.org' Subject:Re:Re: Window Aggregation and Window Join ability not work properly I change to watermark for `datatime` as `datatime` - interval '1' second or watermark for `datatime` as `datatime` but is still not work. At 2021-12-2

Re:Re: Window Aggregation and Window Join ability not work properly

2021-12-22 Thread cy
I change to watermark for `datatime` as `datatime` - interval '1' second or watermark for `datatime` as `datatime` but is still not work. At 2021-12-23 15:16:20, "Yun Gao" wrote: Hi Caiyi, The window need to be finalized with watermark[1]. I noticed that the watermark defined

Re: Window Aggregation and Window Join ability not work properly

2021-12-22 Thread Yun Gao
Hi Caiyi, The window need to be finalized with watermark[1]. I noticed that the watermark defined is `datatime` - INTERVAL '5' MINUTE, it means the watermark emitted would be the maximum observed timestamp so far minus 5 minutes [1]. Therefore, if we want to trigger the window of 16:00 ~ 16: