Re: Flink - dealing with missing events in keyBy window

2021-10-04 Thread Sahar Amgadi
release-1.13/docs/dev/datastream/operators/process_function/#the-keyedprocessfunction > > > --Original Mail -- > *Sender:*Sahar Amgadi > *Send Date:*Fri Oct 1 21:52:29 2021 > *Recipients:*+user > *Subject:*Flink - dealing with missing events i

Flink - dealing with missing events in keyBy window

2021-10-01 Thread Sahar Amgadi
Hey guys, I have a flink stream which receives sensors data every 5 seconds. The data is being processed using "keyBy" in a "Sliding Window" method using ProcessWindowFunction. The key is the sensorID. When one of the sensors is not sending any data more than 5 seconds, I need the stream to recogni