Late events in streaming using SQL API

[Juan Gentile]

Hello,

 

We are using the SQL api and we were wondering if it’s possible to capture and log late events. We could not find a way considering the time window is managed inside the SQL.

Is there a way to do this?

 

Thank you,

Juan

[Timo Walther]

Hi Juan,

currently, there is no way of handling late events in SQL. This feature got requested multiple times so it is likely that some contributor will pick it up soon. I filed FLINK-10031 [1] for it. There is also [2] that aims for improving the situation with time windows.

Regards,
Timo

[1] https://issues.apache.org/jira/browse/FLINK-10031
[2] https://issues.apache.org/jira/browse/FLINK-6969
Am 02.08.18 um 14:36 schrieb Juan Gentile:

Hello,

 

We are using the SQL api and we were wondering if it’s possible to capture and log late events. We could not find a way considering the time window is managed inside the SQL.

Is there a way to do this?

 

Thank you,

Juan