[
https://issues.apache.org/jira/browse/FLUME-762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13100127#comment-13100127
]
[email protected] commented on FLUME-762:
-----------------------------------------------------
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/1739/
-----------------------------------------------------------
(Updated 2011-09-08 07:25:11.363988)
Review request for jmhsieh.
Changes
-------
Handled the InterruptedException which results into driver abort. Updated the
test to add that scenario and refactor the test classes.
Looks like my profiles got messed up which caused the tab/space formatting
problems. sorry about that.
thanx
Prasad
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 (updated)
-----
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
