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.4, v0.9.3
            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