Re: TumblingEventTimeWindows with time characteristic set to 'ProcessingTime'

2016-08-17 Thread Stephan Ewen
You can still mix processing time and event time. You only need to set the base environment to event time in order to activate the timestamp/watermark transport. On Wed, Aug 17, 2016 at 1:40 PM, Al-Isawi Rami wrote: > Hi Till, > > Yes, I understand that. I am just asking why. If I am assigning t

Re: TumblingEventTimeWindows with time characteristic set to 'ProcessingTime'

2016-08-17 Thread Al-Isawi Rami
Hi Till, Yes, I understand that. I am just asking why. If I am assigning the timestamps. why can’t flink deal with the window based on the event time? i.e TumblingEventTimeWindows. Why should I set the whole env to be ticking on event time? It is just that I have some windows that needs to be

Re: TumblingEventTimeWindows with time characteristic set to 'ProcessingTime'

2016-08-17 Thread Till Rohrmann
Hi Rami, have you set the event time characteristic to event time with env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);? Otherwise the event time windows won’t work. Cheers, Till ​ On Tue, Aug 16, 2016 at 2:42 PM, Al-Isawi Rami wrote: > Hi, > > Why this combination is not possibl

TumblingEventTimeWindows with time characteristic set to 'ProcessingTime'

2016-08-16 Thread Al-Isawi Rami
Hi, Why this combination is not possible? even though I am setting "assignTimestampsAndWatermarks “ correctly on the DataStream. I would like Flink to be ticking on processing time, but also utilize the TumblingEventTimeWindows which is based on event time. It is not possible because of : java