Hi Maciej, there is no documentation for it (besides in the code itself) because it's an experimental flag. What would you expect allow-lateness to do outside the context of a window? Maybe you'd also be interested in CURRENT_WATERMARK()[1][2] which will be released with 1.14 and allows some level of late data handling.
[1] https://issues.apache.org/jira/browse/FLINK-22737 [2] https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/#temporal-functions Best Ingo On Tue, Aug 10, 2021 at 3:21 PM Maciej Bryński <mac...@brynski.pl> wrote: > Hi Guys, > I was checking if anything changed recently with allowed lateness > support in Flink SQL and I found this PR: > https://github.com/apache/flink/pull/16022 > > Is there any documentation for table.exec.emit.allow-lateness ? > Is this option working only in window agregation? > > Regards, > -- > Maciek Bryński >
