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 <rami.al-is...@comptel.com> wrote: > 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.lang.RuntimeException: Record has Long.MIN_VALUE timestamp (= no > timestamp marker). > > Regards, > -Rami > Disclaimer: This message and any attachments thereto are intended solely > for the addressed recipient(s) and may contain confidential information. If > you are not the intended recipient, please notify the sender by reply > e-mail and delete the e-mail (including any attachments thereto) without > producing, distributing or retaining any copies thereof. Any review, > dissemination or other use of, or taking of any action in reliance upon, > this information by persons or entities other than the intended > recipient(s) is prohibited. Thank you. >
