Hi Colin,
Flink's SQL runner does not support handling of late data yet. At the
moment, late events are simply dropped.
We plan to add support for late data in a future release.
The "withIdleStateRetentionTime" parameter only applies to non-windowed
aggregation functions and controls when they ca
Hello,
I've been given some flink application code and asked to implement and
ensure that our query is updated for late arriving entries. We're currently
creating a table using a Tumbling SQL query similar to the first example in
https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/ta
