hey flink friends π, is it possible at scale that we could have events being leaked from operators of a keyed stream? for instance, we have a kafka and kinesis data source that is keyed into streams by 'user' and then this data stream gets sessionised.
we have noticed that there is output data (at high volume traffic) where it looks as though the data of one user (in theory one keyed stream) is cut into two overlapping streams.
note: we are sessionising here, so essentially we have two session windows where there should be one. i'm still trying to investigate this more thoroughly so i'm just wondering if anyone has any thoughts off the top of this?
thanks!