GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/5563
[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.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink
jira-8543-fix-avro-writer-stream-close
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/5563.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #5563
----
commit 548dea4c0811ffbfaf1566aaae88551f29eb5af9
Author: Aljoscha Krettek <aljoscha.krettek@...>
Date: 2018-02-22T16:24:33Z
[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.
----
---
