[FLINK-20443] ContinuousProcessingTimeTrigger doesn't fire at the end of the window - ASF JIRA

XML

Word

Printable

JSON

srcStream
.timeWindowAll(Time.seconds(60))
.trigger(ContinuousProcessingTimeTrigger.of(Time.seconds(10)))...

This can correctly calculate the following interval result : 0-10s 10-20s 20-30s 30-40s 40-50s

But this lost data which was send in 50-60s.

Because when the first window ends, the time is 59.9999s, it is not equal to window-end-time(60s).So it will not enter the if judgment.

relates to

FLINK-35069 ContinuousProcessingTimeTrigger continuously registers timers in a loop at the end of the window

links to

GitHub Pull Request #14277

(1 links to)