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

Mon, 20 Feb 2023 21:46:57 -0800 

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

回复