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>