13MaxG opened a new pull request, #34484: URL: https://github.com/apache/beam/pull/34484
Proposing a solution to https://github.com/apache/beam/issues/26190 . It appears the Flatten was not setting a watermark, which caused following steps not to execute. The issue was returning errors on beam versions 2.39 onwards, and it potentially produced unstable results before 2.39. There are meaningful TODOs mentioned: `# TODO(robertwb): Possibly fuse multi-input flattens into one of the stages.` `# TODO(pabloem): Consider case where there are various producers` It makes parts of the code redundant, a refactoring could be considered. For now, I would like to test if this change evaluate correctly. -- 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: github-unsubscr...@beam.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
