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