CODEWITHSUNDEEP
apache-flinkflink-streamingflink-sql
J.Doe
J.Doe

Reputation: 11

flink: use allowedLateness in flink sql api

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

Upvotes: 1

Views: 456

Answers (1)

Fabian Hueske
Fabian Hueske

Reputation: 18987

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

Upvotes: 1

Related Questions