tree 070d6fbc066a4a5220d2f7ef20f60ad04b63ad83
parent a0193f10af66c9efa0d9abbe975853f8447c4bf5
author Aljoscha Krettek <aljoscha.krettek@gmail.com> 1519316673 +0100
committer Aljoscha Krettek <aljoscha.krettek@gmail.com> 1519675922 +0100

[FLINK-8543] Don't call super.close() in AvroKeyValueSinkWriter

The call to keyValueWriter.close() in AvroKeyValueSinkWriter.close()
will eventually call flush() on the wrapped stream which fails if we
close it before(). Now we call flush ourselves before closing the
KeyValyeWriter, which internally closes the wrapped stream eventually.