Re: Usage of "onTime" in ProcessFunction

2018-08-31 Thread Boris Lublinsky
Thanks Andrey I do not have event time, dealing only with process time. My process gets 2 types of messages: 1. Start processing, which starts the timer, creates a GUID and outputs event to another stream for the actual processing. Lets say at time 45s and I want to make sure that my result will

Re: Usage of "onTime" in ProcessFunction

2018-08-31 Thread Andrey Zagrebin
Hi, the timers are scoped to the current key when you apply a processing function to a KeyedStream. If you register more than one timer for a particular key and timestamp, you will get only one onTimer callback, see also in docs [1]. Timers registered in a processing function will trigger only