Re: Event-time tumbling window doesn't fire- Flink 1.2.0, Kafka-0.8_2.10

2017-03-09 Thread Aljoscha Krettek
Great you could figure it out! And thanks for letting us know. On Wed, Mar 8, 2017, at 03:03, Sam Huang wrote: > So sorry I forgot to reply. I've solved the problem, turns out I didn't > input > data which generates a watermark greater than my first window end time, > so > no window was triggered.

Re: Event-time tumbling window doesn't fire- Flink 1.2.0, Kafka-0.8_2.10

2017-03-07 Thread Sam Huang
So sorry I forgot to reply. I've solved the problem, turns out I didn't input data which generates a watermark greater than my first window end time, so no window was triggered. -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Event-time-tumbl

Re: Event-time tumbling window doesn't fire- Flink 1.2.0, Kafka-0.8_2.10

2017-03-01 Thread Aljoscha Krettek
Hi Sam, do you have an idea what the timestamps in your data are, i.e. the tuple.f1 field you're extracting. What you could try is instead of windowing simply print your data and observe the timestamps. Maybe we can learn something from this about why the window doesn't trigger. Best, Aljoscha On