Re: Whether Flink SQL window operations support "Allow Lateness and SideOutput"?

2023-02-21 文章 Weihua Hu 
Hi,

Maybe you can use CURRENT_WATERMARK()[1]  to handle some late data.


[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/


Best,
Weihua


On Tue, Feb 21, 2023 at 1:46 PM wang <24248...@163.com> wrote:

> Hi dear engineers,
>
>   One question as title: Whether Flink SQL window operations support
> "Allow Lateness and SideOutput"?
>
>   Just as supported in Datastream api (allowedLateness
> and sideOutputLateData) like:
>
> SingleOutputStreamOperator<> sumStream = dataStream.keyBy()
> .timeWindow()
>.
> allowedLateness(Time.minutes(1))
>.
> sideOutputLateData(outputTag)
>.sum();
>
> Thanks && Regards,
> Hunk
>
>

Whether Flink SQL window operations support "Allow Lateness and SideOutput"?

2023-02-20 文章 wang 
Hi dear engineers,


  One question as title: Whether Flink SQL window operations support "Allow 
Lateness and SideOutput"?


  Just as supported in Datastream api (allowedLateness and sideOutputLateData) 
like:


SingleOutputStreamOperator<>sumStream = dataStream.keyBy().timeWindow()
   
.allowedLateness(Time.minutes(1)) 
   
.sideOutputLateData(outputTag)
   .sum();


Thanks && Regards,
Hunk