Hi,
How are your registering your event time timers on processElement?
If you are continuously registering them, and watermarks are correctly
generated upstream, then the onTimer method should be invoked properly.
For your 1-to-many case, I would assume that whenever a new key arrives
(that
Hello.
I'm joining several data streams, using ConnectedStreams. Let's say something
like A connect B which outputs AB, and then I join AB with C, which outputs ABC.
However, the relationship between A and B, or AB and C may be of 1 to many, or
1 to 1, depending on the case. For the 1 to 1,
