I am using Flink to aggregate the data from kafka topics. I am using a tumble window of 1 hour, with the time characteristic set to Event Time. I am also using AscendingTimestampExtractor and assigning watermarks to the input based on a particular field value in json.
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
We can assume that the JSON field used for watermarking has a time value similar to that of system clock.
If I deploy the job at 3:25 pm, when can I expect the flink aggregated output? Will it be at 4:00 pm, 5:00 pm ... or 3:25 pm -4:25 pm, 4:25 pm -5 :25 pm....