Github user IgorBerman commented on the issue:
https://github.com/apache/flink/pull/5563
@aljoscha, sorry for late response, I needed to refresh this piece of code.
Overall, I think it's ok. I mean at the end I've used same scheme of
implementing SinkWriter as other examples, so if you refactoring something in
hierarchy then it should have same handling.
From avro file perspective(internal writer) you are closing it, which would
be sufficient. What problems do you expect here?---
