damccorm opened a new issue, #23763: URL: https://github.com/apache/beam/issues/23763
### What happened? Right now, if you have a streaming job with periodic impulse as your source, the watermark will not get updated until the periodic impulse completes. This means that if you have something like: ``` pipeline | PeriodicImpulse(time.now(), time.now()+1000000, 1) | beam.Map(do_stuff) | beam.WindowInto(window.FixedWindows(2)) | beam.combiners.Count.PerElement() | beam.Map(log_output) ``` the pipeline will hang indefinitely and never log anything. If we properly emitted watermarks, it would log output every 2 seconds. ### Issue Priority Priority: 2 ### Issue Component Component: sdk-py-core -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
