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.

----


---

Reply via email to