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 previously has not seen events with the same key from other streams), an event time timer is registered to be fired after a certain amount of time which you allow to wait for other matching join records. Does this help? Cheers, Gordon -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
