Query regarding tumbling event time windows with ingestion time

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

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