Please register the writeAvroFn. For the structural DoFns to function properly on runners that aren't the Direct Runner, the types need to be registered at init time, so they can be materialized properly on workers.
[ Full content available at: https://github.com/apache/beam/pull/6484 ] This message was relayed via gitbox.apache.org for [email protected]
