Hello,

With time characteristic set to IngestionTime I expected 
"timeWindow(Time.minutes(3))" to NOT produce any records in the first 3 minutes 
of running the job, and yet it does emit the record before 3 minutes elapse.
Am I doing something wrong? Or my understanding of timeWindow is incorrect?

For example, in Flink UI I see:

TriggerWindow(TumblingEventTimeWindows(180000), 
AggregatingStateDescriptor{serializer=org.apache.flink.api.java.typeutils.runtime.PojoSerializer@7c810ef9,
 aggFunction=nextgen.McdrAggregator@7d7758be}, EventTimeTrigger(), 
WindowedStream.aggregate(WindowedStream.java:752)) -> Map

With "duration" 42s and "records sent" 689516.

I expected no records would be sent out until 180000 ms elapse.

Thanks,
Alex Nekrassov
nekras...@att.com<mailto:nekras...@att.com>

Reply via email to