Merge pull request #9111 [BEAM-7747] Propertly close file handle in F…

…astAvroSink. [BEAM-7747] Close the file handle owned by fastavro.write.Writer in _FastAvroSink.close().
apache · Jul 24, 2019 · 09fe498 · 09fe498
2 parents 4935d0c + 2f239e4
commit 09fe498
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/sdks/python/apache_beam/io/avroio.py b/sdks/python/apache_beam/io/avroio.py
@@ -629,3 +629,4 @@ def write_record(self, writer, value):
 
   def close(self, writer):
     writer.flush()
+    writer.fo.close()