Hi!
If you look into the code of WindowOperator you'll see a cleanup timer is
registered for each element. This cleanup timer is used to deal with late
records. I suppose that is the timer which calls the onEventTime in your
trigger.
Trigger is a class for the user to decide whether to fire a win
Hi Caizhi,
Thanks for responding. What i mean specifically is that if I do
something like this
env
.addSource(events)
.keyBy()
.window(TumblingEventTimeWindows.of(Time.seconds(1)))
.trigger(new EmptyTrigger())
.process(new
Hi!
I don't quite understand this problem. But if you look into
WindowedStream#trigger you'll find that the trigger
of WindowOperatorBuilder will change when you call that method, and thus
the default trigger will be overwritten by calling WindowedStream#trigger.
Aeden Jameson 于2021年9月1日周三 上午12:
Flink Version: 1.13.2
In the section on Default Triggers of Window Assigners the documentation
States
By specifying a trigger using trigger() you are overwriting the default
trigger of a WindowAssigner. For example, if you specify a CountTrigger for
TumblingEventTimeWindows you will no longer get
