Hi, Maybe you can use CURRENT_WATERMARK()[1] to handle some late data.
[1] https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/ Best, Weihua On Tue, Feb 21, 2023 at 1:46 PM wang <24248...@163.com> wrote: > Hi dear engineers, > > One question as title: Whether Flink SQL window operations support > "Allow Lateness and SideOutput"? > > Just as supported in Datastream api (allowedLateness > and sideOutputLateData) like: > > SingleOutputStreamOperator<> sumStream = dataStream.keyBy() > .timeWindow() > . > allowedLateness(Time.minutes(1)) > . > sideOutputLateData(outputTag) > .sum(); > > Thanks && Regards, > Hunk > >
