Review Board 1.7.22


[Flume-1881] Set log level for File Channel's checkpoint time warning to INFO (in behalf of Connor Woodson)

Review Request #9422 - Created Feb. 13, 2013 and updated

Alexander Alten-Lorenz
Flume-1881
Reviewers
Flume
flume-git
As mentioned here:
(http://mail-archives.apache.org/mod_mbox/flume-dev/201301.mbox/%3CCAH0o75Og85wn_Yx%2BmAQKqTVrKdRzv7DToGo%2B%3DiRqtnn3%2BoD_5g%40mail.gmail.com%3E)
There is an unnecessary WARN message played sometimes when the File Channel starts.

 
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFile.java
Revision 1db3717 New Change
[20] 464 lines
[+20] [+] protected RandomAccessFile getFileHandle() {
465
          && lastCheckpointWriteOrderID <= checkpointWriteOrderID) {
465
          && lastCheckpointWriteOrderID <= checkpointWriteOrderID) {
466
        LOG.info("fast-forward to checkpoint position: "
466
        LOG.info("fast-forward to checkpoint position: "
467
                  + lastCheckpointPosition);
467
                  + lastCheckpointPosition);
468
        fileChannel.position(lastCheckpointPosition);
468
        fileChannel.position(lastCheckpointPosition);
469
      } else {
469
      } else {
470
        LOG.warn("Checkpoint for file(" + file.getAbsolutePath() + ") "
470
        LOG.info("Checkpoint for file(" + file.getAbsolutePath() + ") "
471
            + "is: " + lastCheckpointWriteOrderID + ", which is beyond the "
471
            + "is: " + lastCheckpointWriteOrderID + ", which is beyond the "
472
            + "requested checkpoint time: " + checkpointWriteOrderID
472
            + "requested checkpoint time: " + checkpointWriteOrderID
473
            + " and position " + lastCheckpointPosition);
473
            + " and position " + lastCheckpointPosition);
474
      }
474
      }
475
    }
475
    }
[+20] [20] 109 lines
  1. flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFile.java: Loading...