Review Board 1.7.22


FLUME-1824. Inflights can complete successfully even if checkpoint fails

Review Request #8875 - Created Jan. 8, 2013 and submitted

Hari Shreedharan
FLUME-1824
Reviewers
Flume
flume-git
Split out checkpoint method to beginCheckpoint.
All tests pass.
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStore.java
Revision 13b50da New Change
[20] 33 lines
[+20]
34
    this.capacity = capacity;
34
    this.capacity = capacity;
35
    this.name = name;
35
    this.name = name;
36
  }
36
  }
37

    
   
37

   
38

    
   
38

   

    
   
39
  abstract void beginCheckpoint() throws IOException;
39
  abstract void checkpoint() throws IOException;
40
  abstract void checkpoint() throws IOException;
40
  abstract void incrementFileID(int fileID);
41
  abstract void incrementFileID(int fileID);
41
  abstract void decrementFileID(int fileID);
42
  abstract void decrementFileID(int fileID);
42
  abstract ImmutableSortedSet<Integer> getReferenceCounts();
43
  abstract ImmutableSortedSet<Integer> getReferenceCounts();
43
  abstract long get(int index);
44
  abstract long get(int index);
[+20] [20] 33 lines
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFile.java
Revision 186b15a New Change
 
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEventQueue.java
Revision 74a2bc8 New Change
 
  1. flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStore.java: Loading...
  2. flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFile.java: Loading...
  3. flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEventQueue.java: Loading...