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

Reply via email to