Hi Flink community, In Flink DataStream Java API, user can get get data that was discarded as late using WindowedStream.sideOutputLateData(OutputTag) (see [1]). I'm wondering what is the best way for user to achieve this in Flink SQL?
For background, we are providing pure sql deployment to our internal users which means user won't be using Flink Table API directly. They will write Flink SQL script, with Java only used for UDF. Would appreciate if any one here can share your insights or experiences. Thanks! [1] https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/operators/windows/#getting-late-data-as-a-side-output
