apache-flink - 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”并将延迟数据作为辅助输出吗

Answer 1

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