Also, are the event time timers and processing time timers handled separately
- ie, if I register event time timer and then use the same timestamp to delete
processing time timer - will it remove the event time timer registration ?
In the example
https://github.com/streaming-with-flink/examples-scala/blob/master/src/main/scala/io/github/streamingwithflink/chapter6/CoProcessFunctionTimers.scala#L87
should the delete and register be on the processing time timer and is it ok to
delete event time timer and register processing time timer ?
override def processElement2( switch: (String, Long), ctx:
CoProcessFunction[SensorReading, (String, Long), SensorReading]#Context,
out: Collector[SensorReading]): Unit = {
// enable reading forwarding forwardingEnabled.update(true) // set
disable forward timer val timerTimestamp =
ctx.timerService().currentProcessingTime() + switch._2 val curTimerTimestamp
= disableTimer.value() if (timerTimestamp > curTimerTimestamp) { //
remove current timer and register new timer
ctx.timerService().deleteEventTimeTimer(curTimerTimestamp)
ctx.timerService().registerProcessingTimeTimer(timerTimestamp)
disableTimer.update(timerTimestamp) } }
On Sunday, July 14, 2019, 01:52:44 PM EDT, M Singh <[email protected]>
wrote:
Hi:
If I register both event time timer and processing time timer with the same
timestamp for a particular key - will they both fire or only one will fire ? If
only one, what will be its time domain ?
Thanks
