Triggers for late elements

[Harshvardhan Agrawal]

Hello,

I am trying to understand the behaviour of Triggers in the case where we receive late elements for a window. Does Flink always fires a window each time it receives late element i.e. if I receive 10 late elements, would it fire 10 times?

Is there any specific example I could refer to understand the how this works?

--

[Hequn Cheng]

Hi harshvardhan,

No, by default, late elements will be thrown away. There are documents about window here[1].

Best, Hequn

[1] https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/operators/windows.html#windows

On Mon, Jul 23, 2018 at 1:34 AM, Harshvardhan Agrawal <[hidden email]> wrote:

Hello,

I am trying to understand the behaviour of Triggers in the case where we receive late elements for a window. Does Flink always fires a window each time it receives late element i.e. if I receive 10 late elements, would it fire 10 times?

Is there any specific example I could refer to understand the how this works?

--