You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@beam.apache.org by Thomas Weise <th...@apache.org> on 2017/05/03 04:57:18 UTC

Future processing time timers and final watermark

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