[FLINK-5149] ContinuousEventTimeTrigger doesn't fire at the end of the window - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Bug
Status: Closed
Priority: Major
Resolution: Fixed
Affects Version/s: 1.1.3, 1.2.0
Fix Version/s: 1.1.4, 1.2.0
Component/s: API / DataStream
Labels:
None

Description

The ContinuousEventTimeTrigger registers a timer when elements arrive. The timers might be registered past the end of the window. In this case, the window is cleaned up and doesn't fire at all. That is certainly not what users have in mind when they use the custom trigger.

I proposed to let it behave like a normal EventTimeTrigger in addition to its continuous firing capabilities. So it should fire at the end of the window regardless of timers set.