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/31ebd3c3
Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/31ebd3c3
Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/31ebd3c3

Branch: refs/heads/flume-1.3.0
Commit: 31ebd3c38c0616e02b707548850ed3e22ffd0fdb
Parents: 38e67d5
Author: Brock Noland <[email protected]>
Authored: Mon Dec 10 15:28:21 2012 -0600
Committer: Hari Shreedharan <[email protected]>
Committed: Thu Dec 20 00:12:51 2012 -0800

----------------------------------------------------------------------
 .../file/EventQueueBackingStoreFactory.java        |    6 +++---
 1 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flume/blob/31ebd3c3/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

Reply via email to