flink: use allowedLateness in flink sql api

Question

I'm using flink sql api and I have a sql like

Table result2 = tableEnv.sqlQuery(
    "SELECT user, SUM(amount) " +
    "FROM Orders " +
    "GROUP BY TUMBLE(proctime, INTERVAL '1' DAY), user"
);

Can I enable "allowedLatenness" and getting late data as a side output

Answer 1

Late data handling is not supported in Flink SQL yet (version 1.5.0). Late rows are just dropped.