Hi, in my understanding, Flink only support to get late data by side output in data stream api currently. For Table API/SQL, unfortunately, late events will always be dropped.
You can see this link as reference: https://stackoverflow.com/questions/60218235/using-event-time-with-lateness-in-flink-sql-windows > On 31 Mar 2022, at 5:38 AM, liuxiangcao <xiangcaohe...@gmail.com> wrote: > > Hi Flink community, > > In Flink DataStream Java API, user can get get data that was discarded as > late using WindowedStream.sideOutputLateData(OutputTag) (see [1]). I'm > wondering what is the best way for user to achieve this in Flink SQL? > > For background, we are providing pure sql deployment to our internal users > which means user won't be using Flink Table API directly. They will write > Flink SQL script, with Java only used for UDF. > > Would appreciate if any one here can share your insights or experiences. > Thanks! > > [1] > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/operators/windows/#getting-late-data-as-a-side-output > > >
