je-ik commented on PR #28567:
URL: https://github.com/apache/beam/pull/28567#issuecomment-1731013172
> Having said that, the current approach also works correctly when
`requiresStableInput` is set since all the buffered data is emitted after
checkpoint completes and the output watermark finally becomes equal to
MAX_WATERMARK (i have run multiple jobs to verify the behavior).
This seems to be the source of troubles. See my comment [here][1].
[1]: https://github.com/apache/beam/issues/28554#issuecomment-1730987899
--
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]
