flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Janardhan Reddy <janardhan.re...@olacabs.com>
Subject Query regarding tumbling event time windows with ingestion time
Date Tue, 29 Nov 2016 18:25:34 GMT

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.


View raw message