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

Reply via email to