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

Reply via email to