flink: keyed process function, why are timestamp of register event timer different as "on timer" function timestamp

[Xiangyu Su]

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

[Dian Fu]

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 <[hidden email]> 写道：

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