Hi,

We are using beam's PROCESSING_TIME based timers in a DoFn that operates on
a KV pair in a global window.

We are using 2 timers in our business logic and in one of our timer's
callback function, we are setting the second timer to expire after x
seconds. However, the observation is that this second timer is expiring
early than expected, and in some cases, it's expiring immediately.

We are setting both the timers using these lines of code:

clearRaisedTimer.offset(Duration.standardSeconds(60)).setRelative();


Is this a known issue, or are we missing something?

Thanks,
Sahil

Reply via email to