Review Board 1.7.22


FLUME-2037. testDataFilesRequiredByBackupNotDeleted is flakey

Review Request #11002 - Created May 8, 2013 and updated

Hari Shreedharan
FLUME-2037
Reviewers
Flume
flume-git
Updated the test to make it more tolerant but still correct.
Ran the test - works fine.
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Log.java
Revision e61437d New Change
[20] 814 lines
[+20] [+] private void lockExclusive(){
815
    }
815
    }
816
  }
816
  }
817

    
   
817

   
818
  void shutdownWorker() {
818
  void shutdownWorker() {
819
    String msg = "Attempting to shutdown background worker.";
819
    String msg = "Attempting to shutdown background worker.";
820
    System.out.println(msg);

   
821
    LOGGER.info(msg);
820
    LOGGER.info(msg);
822
    workerExecutor.shutdown();
821
    workerExecutor.shutdown();
823
    try {
822
    try {
824
      workerExecutor.awaitTermination(10, TimeUnit.SECONDS);
823
      workerExecutor.awaitTermination(10, TimeUnit.SECONDS);
825
    } catch (InterruptedException e) {
824
    } catch (InterruptedException e) {
[+20] [20] 346 lines
flume-ng-channels/flume-file-channel/src/test/java/org/apache/flume/channel/file/TestFileChannelRestart.java
Revision dc6fc45 New Change
 
  1. flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Log.java: Loading...
  2. flume-ng-channels/flume-file-channel/src/test/java/org/apache/flume/channel/file/TestFileChannelRestart.java: Loading...