Re: Re: Re: Flink Window with multiple trigger condition

2020-05-30 Thread aj
t;[2] > https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/operators/process_function.html#example > > > --Original Mail -- > *Sender:*aj > *Send Date:*Fri May 29 02:07:33 2020 > *Recipients:*Yun Gao > *CC:*user > *Su

Re: Re: Re: Flink Window with multiple trigger condition

2020-05-28 Thread Yun Gao
Window with multiple trigger condition Hi, I have implemented the below solution and its working fine but the biggest problem with this is if no event coming for the user after 30 min then I am not able to trigger because I am checking time diff from upcoming events. So when the next event comes than

Re: Re: Flink Window with multiple trigger condition

2020-05-28 Thread aj
perators/process_function.html#example > > Best, > Yun > > > > --Original Mail -- > *Sender:*aj > *Send Date:*Sun May 24 01:10:55 2020 > *Recipients:*Tzu-Li (Gordon) Tai > *CC:*user > *Subject:*Re: Flink Window with multiple trigg

Re: Re: Flink Window with multiple trigger condition

2020-05-24 Thread Yun Gao
Hi, First sorry that I'm not expert on Window and please correct me if I'm wrong, but from my side, it seems the assigner might also be a problem in addition to the trigger: currently Flink window assigner should be all based on time (processing time or event time), and it might be hard