Hi Xiangyu, What do you mean by "should be triggered by using same time"? The timestamp of the onTimer callback is not the watermark time. It's the timestamp which is registered in the call of registerEventTimeTimer.
Regards, Dian > 在 2019年9月19日，下午11:29，Xiangyu Su <xian...@smaato.com> 写道： > > Hi User, > > We are using keyed process function with Event time for flink streaming > application. > We register event time on "processElement" function, and mentioned that > "onTimer" function had different "timestamp" as registered on > "processElement" function. > > If we understand correctly, "onTimer" should be triggered by using same > time(see flink api: InternalTimerServiceImpl.advanceWatermark ) > > thanks for any suggestion > > Best regards > Xiangyu > >
