Re: Handling late events with Table API / SQL

2024-03-07 Thread Sunny S
urse of the operator receiving the first event that belongs to this window until the time this window fires. Please help understanding these. Thanks From: Feng Jin Sent: 06 March 2024 07:08 To: Sunny S Cc: user@flink.apache.org Subject: Re: Handling

Handling late events with Table API / SQL

2024-03-05 Thread Sunny S
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 (   'conne