You can use the CURRENT_WATERMARK(rowtime) function for some filtering, please refer to [1] for details.
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/ Best, Feng On Wed, Mar 6, 2024 at 1:56 AM Sunny S <sunny8...@outlook.in> wrote: > Hi, > > I am using Flink SQL to create a table something like this : > > CREATE TABLE some-table ( > ..., > ..., > ..., > ..., > event_timestamp as TO_TIMESTAMP_LTZ(event_time*1000, 3), > WATERMARK FOR event_timestamp AS event_timestamp - INTERVAL '30' SECOND > ) WITH ( > 'connector' = 'kafka', > 'topic' = 'some-topic', + > 'properties.bootstrap.servers' = 'localhost:9092', > 'properties.group.id' = 'testGroup', > 'value.format' = 'csv' > ) > > I want to understand how can I deal with late events / out of order events > when using Flink SQL / Table API? How can I collect the late / out of order > events to a side output with Table API / SQL? > > Thanks >
