Thank you for your efforts! I think that Qingsheng reported my concerns about discrepancies between event time from the external system and current system time in the Flink cluster in a more concrete fashion. Thank you for the catch!
The FLIP definitely makes sense and would love to see your fixes soon! Thanks On Apr 29, 2024 at 08:54 +0200, jialiang tan <tanjialiang1...@gmail.com>, wrote: > Thanks Qingsheng for the patient guidance! And sorry to everyone for > wasting your time. > > I suddenly realised that my implementation is wrong. > > In my implementation the FetchTime and EventTime do not come from the same > record and I am making this stupid mistake :( . > > I need some time to think about it and will start a new discussion when I > am ready. > > Best, > JiaLiang.
