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

Re: Handling late events with Table API / SQL

2024-03-05 Thread Feng Jin
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 wrote: > Hi, > > I am using Flink SQL to