[ 
https://issues.apache.org/jira/browse/FLUME-857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Prasad Mujumdar resolved FLUME-857.
-----------------------------------

    Resolution: Fixed

Flume-857 - Handle IOException in close() for retry sinks.
Patch committed to trunk
                
> CollectorSink can get stuck into perpetual close() if the underlying sinks 
> throws IOExceptions for both append and close.
> -------------------------------------------------------------------------------------------------------------------------
>
>                 Key: FLUME-857
>                 URL: https://issues.apache.org/jira/browse/FLUME-857
>             Project: Flume
>          Issue Type: Bug
>    Affects Versions: v0.9.3, v0.9.4
>            Reporter: Prasad Mujumdar
>            Assignee: Prasad Mujumdar
>             Fix For: v0.9.5
>
>
> The CollectionSink create a chain of sinks on top of the underlying sink to 
> perform roll and retries upon failures. The stubborn append reopens the 
> downstream sink and retries the append once. The insistent append keeps 
> retrying the append. 
> Now if any errors (like network or HDFS datanodes shutdown) cause the 
> downstream sink to throw IOException on append, the stubborn append will try 
> to close that sink and reopen. If the close also throws an IOException, then 
> sink chain doesn't get properly closed. This results into the collectorsink 
> skipping the open and perpetually failing on  append/close.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

Reply via email to