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). Поздние ряды просто сбрасываются.