Re: Window + Reduce produces more than 1 output per window

Hello Piotrek! Thanks for answering! Yes I have already changed the "TimeCharacteristic" to "ProcessingTime". I need it for the ".setWriteTimestampToKafka(true)" option as I use the timestamp in the Kafka consumer who reads this app's output. I have already changed the code a bit for using Ke

Window + Reduce produces more than 1 output per window

Hello everybody! First of all, thanks for reading :D I am currently working on my bachelor's final project which is a comparison between Spark Streaming and Flink. Now let's focus on the problem: - THE PROBLEM: the problem is that my program is writing to Kafka more than once every window (