Updated Branches: refs/heads/flume-1.3.0 2a8c3450c -> cb418c9bb
FLUME-1577: CHECKPOINT_INCOMPLETE should be synced to disk before starting the checkpoint. (Hari Shreedharan via Brock Noland) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/cb418c9b Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/cb418c9b Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/cb418c9b Branch: refs/heads/flume-1.3.0 Commit: cb418c9bb86173c64ff5a6ae37adb723796ad222 Parents: 2a8c345 Author: Brock Noland <[email protected]> Authored: Thu Sep 13 15:17:34 2012 -0500 Committer: Brock Noland <[email protected]> Committed: Thu Sep 13 15:18:19 2012 -0500 ---------------------------------------------------------------------- .../channel/file/EventQueueBackingStoreFile.java | 1 + 1 files changed, 1 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/cb418c9b/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFile.java ---------------------------------------------------------------------- diff --git a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFile.java b/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFile.java index 4717055..eab9e4a 100644 --- a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFile.java +++ b/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFile.java @@ -103,6 +103,7 @@ abstract class EventQueueBackingStoreFile extends EventQueueBackingStore { // Start checkpoint elementsBuffer.put(INDEX_CHECKPOINT_MARKER, CHECKPOINT_INCOMPLETE); + mappedBuffer.force(); setLogWriteOrderID(WriteOrderOracle.next()); LOG.info("Updating checkpoint metadata: logWriteOrderID: "
