Updated Branches: refs/heads/trunk 46659c715 -> e38a3e636
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/e38a3e63 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/e38a3e63 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/e38a3e63 Branch: refs/heads/trunk Commit: e38a3e636394687710b293d303813fe0df047fff Parents: 46659c7 Author: Brock Noland <[email protected]> Authored: Thu Sep 13 15:17:34 2012 -0500 Committer: Brock Noland <[email protected]> Committed: Thu Sep 13 15:17:34 2012 -0500 ---------------------------------------------------------------------- .../channel/file/EventQueueBackingStoreFile.java | 1 + 1 files changed, 1 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/e38a3e63/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: "
