Whenever processing time is advanced, the watermark timers are triggered, so we need to keep it advancing. The sleep releases the checkpoint lock which would otherwise prevent the the source wrapper from making progress.
[ Full content available at: https://github.com/apache/beam/pull/6385 ] This message was relayed via gitbox.apache.org for [email protected]
