You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flume.apache.org by "jiraposter@reviews.apache.org (JIRA)" <ji...@apache.org> on 2011/09/08 01:20:12 UTC

[jira] [Commented] (FLUME-762) DirectDriver should reopen the source/sink if the append or next throws an exception

    [ https://issues.apache.org/jira/browse/FLUME-762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13099652#comment-13099652 ] 

jiraposter@reviews.apache.org commented on FLUME-762:
-----------------------------------------------------


-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/1739/
-----------------------------------------------------------

Review request for jmhsieh.


Summary
-------

If the source or sink throws an exception, close, reopen and retry it. This way the flow can continue after minor/recoverable errors.


This addresses bug FLUME-762.
    https://issues.apache.org/jira/browse/FLUME-762


Diffs
-----

  flume-core/src/main/java/com/cloudera/flume/core/connector/DirectDriver.java 0466394 
  flume-core/src/test/java/com/cloudera/flume/core/connector/TestDirectDriverExp.java PRE-CREATION 

Diff: https://reviews.apache.org/r/1739/diff


Testing
-------


Thanks,

Prasad



> DirectDriver should reopen the source/sink if the append or next throws an exception
> ------------------------------------------------------------------------------------
>
>                 Key: FLUME-762
>                 URL: https://issues.apache.org/jira/browse/FLUME-762
>             Project: Flume
>          Issue Type: Improvement
>          Components: Node
>            Reporter: Prasad Mujumdar
>            Assignee: Prasad Mujumdar
>         Attachments: flume-762.patch
>
>
> Currently, if source or sink throws an exception, the driver bails out resulting the everything to shut down. Alternately, we can try to close and reopen the source or sink, and then attempt to continue. This way we can avoid blocking the flow. If the reopen fails, then it can bail out.

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira