Hi,

While working on SDF support in the Apex runner, I see the scenario where
processing time timers are set in the future. These never trigger, the
topology exits with the final watermark before.

What is the correct way to handle this? Should the final watermark be held
until all processing time timers are cleared?

Thanks,
Thomas

Reply via email to