Updated Branches: refs/heads/trunk 8de68ea63 -> 5f1243251
FLUME-1774: EventBackingStoreFactory error message asks user to delete checkpoint which is now done automatically (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/5f124325 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/5f124325 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/5f124325 Branch: refs/heads/trunk Commit: 5f12432514ccbdda51c8c03cafa9d4512e3a0594 Parents: 8de68ea Author: Brock Noland <[email protected]> Authored: Mon Dec 10 15:28:21 2012 -0600 Committer: Brock Noland <[email protected]> Committed: Mon Dec 10 15:28:21 2012 -0600 ---------------------------------------------------------------------- .../file/EventQueueBackingStoreFactory.java | 6 +++--- 1 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/5f124325/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFactory.java ---------------------------------------------------------------------- diff --git a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFactory.java b/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFactory.java index faec50b..a19bdb4 100644 --- a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFactory.java +++ b/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFactory.java @@ -51,9 +51,9 @@ class EventQueueBackingStoreFactory { + " exists but checkpoint does not. Checkpoint = " + checkpointFile + ", metaDataFile = " + metaDataFile); throw new BadCheckpointException( - "The last checkpoint was not completed correctly. " - + "Please delete all files in the checkpoint directory: " - + checkpointFile.getParentFile()); + "The last checkpoint was not completed correctly, " + + "since Checkpoint file does not exist while metadata " + + "file does."); } } // brand new, use v3
