flink: использовать allowLateness в flink sql api

Question

я использую flink sql api, и у меня есть sql как

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

Могу ли я включить "allowLatenness" и получение поздних данных в качестве побочного вывода

Answer 1

Поздняя обработка данных пока не поддерживается в Flink SQL (версия 1.5.0). Поздние строки просто отбрасываются.