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>
