[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Always trigger calculation of a tumble window in Flink SQL

We have a requirement that always want to trigger a calculation on a timer
basis e.g. every 1 minute.

*If there are records come in flink during the time window then calculate it
with the normal way, i.e. aggregate for each record and getResult() at end
of the time window.*

*If there are no records come in flink during the time window, then send the
last calculated result.*

I know that Flink will not trigger the calculation in the second case(when
no records come in the system during the time window), if there a solution
for me in Flink SQL?

Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/