This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 2d4a17c [BEAM-13430] Partially revert
https://github.com/apache/beam/commit/eaacf709a861ea1c260e3856b720266348b1aecc
(#16419)
add 7b5c4cd [BEAM-12391] update avro sink to close the opened file
handle, instead of getting it by reference from the writer. This ensures that
when we load the python writer implementation we don't run into an attribute
error
add f63451e Merge pull request #16246: [BEAM-12391] update avro sink to
close the opened file handle directly
No new revisions were added by this update.
Summary of changes:
sdks/python/apache_beam/io/avroio.py | 25 ++++++++++++++++++++++---
sdks/python/apache_beam/io/avroio_test.py | 15 +++++++++++++++
2 files changed, 37 insertions(+), 3 deletions(-)