Re: Query regarding tumbling event time windows with ingestion time

Posted by Kostas Kloudas on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Query-regarding-tumbling-event-time-windows-with-ingestion-time-tp10382p10385.html

Hi Janardhan,

After the first windowing operation, the timestamp of the emitted element for each window
will be the (endOfWindow - 1). So in your case, in the second windowing operation (window by 5)
there will be at most one element per window.

I hope this answers your question.

Kostas
 

> On Nov 29, 2016, at 7:25 PM, Janardhan Reddy <[hidden email]> wrote:
>
> Hi,
>
> Suppose we have a stream like this.
>
> someStream.timeWindow(Time.minutes(15)).apply {
> operation A
>
> }.keyby("....").window(TumblingEventTimeWindows.ofseconds(5)).apply {
>
> operation B
>
> }.keyby("....").window(TumblingEventTimeWindows.ofseconds(5)).apply {
>
> operation C
>
> }
>
> Say operation A emits some elements => it would be emitted every 15 minutes.
>
> How would be the window behaviour of where operation B takes place if operation A takes more than 5 seconds with ingestion Time characteristic.  Similarly how would windows behave near operation C if operation B takes more than 5 seconds.
>
>
> Thanks
> Janardhan