Re: A lesson about DoFn retries

2022-09-05 Thread Jan Lukavský
Yes, all portable runners use fusion, it is built into the machinery that translates Pipeline into protobuf representation. It is needed for the ability to run the pipeline efficiently, otherwise there would be too many calls between the runner and SDK harness. Which is why the translation crea

Beam High Priority Issue Report (69)

2022-09-05 Thread beamactions
This is your daily summary of Beam's current high priority issues that may need attention. See https://beam.apache.org/contribute/issue-priorities for the meaning and expectations around issue priorities. Unassigned P1 Issues: https://github.com/apache/beam/issues/23020 [Bug]: Kubernetes s