flink：在 flink sql api 中使用 allowedLateness

Question

我正在使用 flink sql api，我有一个类似的 sql

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

我可以启用"allowedLatenness" 和getting late data as a side output

Answer 1

Flink SQL 尚不支持后期数据处理（1.5.0 版本）。后面的行会被删除。