You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by "Hudson (JIRA)" <ji...@apache.org> on 2013/01/09 03:08:12 UTC
[jira] [Commented] (FLUME-1824) Inflights can complete successfully
even if checkpoint fails
[ https://issues.apache.org/jira/browse/FLUME-1824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13547535#comment-13547535 ]
Hudson commented on FLUME-1824:
-------------------------------
Integrated in flume-trunk #349 (See [https://builds.apache.org/job/flume-trunk/349/])
FLUME-1824: Inflights can complete successfully even if checkpoint fails (Revision 1a2e0d7a7629eb32821c780d48a2c17f4e76a59e)
Result = SUCCESS
brock : http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=1a2e0d7a7629eb32821c780d48a2c17f4e76a59e
Files :
* flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStore.java
* flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEventQueue.java
* flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFile.java
> Inflights can complete successfully even if checkpoint fails
> ------------------------------------------------------------
>
> Key: FLUME-1824
> URL: https://issues.apache.org/jira/browse/FLUME-1824
> Project: Flume
> Issue Type: Bug
> Reporter: Hari Shreedharan
> Assignee: Hari Shreedharan
> Fix For: v1.4.0
>
> Attachments: FLUME-1824.patch
>
>
> In FlumeEventQueue class if a failure happens between:
> {code}
> inflightPuts.serializeAndWrite();
> inflightTakes.serializeAndWrite();
> {code}
> and
> {code}
> backingStore.checkpoint();
> return true;
> {code}
> the channel will not detect an error during replay, but will startup with inflights with correct checksums, but is invalid for the checkpoint.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira