Hi all

I'm doing a fold on a sliding window, using
TimeCharacteristic.EventTime. For output I'm picking the timestamp of
the most recent event in the window, and use that to name the output (to
a file).

My question is: will a second run of Flink on the same set of data (from
Kafka) put the same events in a Window, or are the limits of a window
somehow dependent on the real time of the run.
The windows I'm using are two sliding timeWindow's and one timeWindowAll

Thanks for any answers

Bart van Deenen

Reply via email to