tvalentyn commented on issue #27636: URL: https://github.com/apache/beam/issues/27636#issuecomment-1648688288
Thanks for reaching out and a detailed report. It does look like on DirectRunner the trigger for the first window fired only once instead of twice. There are known limitations in direct runner support for streaming usecases: https://github.com/apache/beam/issues/21987, the last comment in https://github.com/apache/beam/issues/27636 however referred to Dataflow runner. Have you observed this behavior on Dataflow? Off the top of my head I don't know how to simulate a controlled watermark lag on Dataflow easily, looks like TestStream is not supported on Datalfow. The closest instrument I am aware of is https://github.com/apache/beam/blob/master/sdks/python/apache_beam/transforms/periodicsequence.py but that might require additional customization. -- 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]
